From 08ed0a9a5d2a241abe4304e03fab4ae74291e3c9 Mon Sep 17 00:00:00 2001 From: Shadowghost Date: Wed, 4 Sep 2024 17:38:10 +0200 Subject: Cleanup tasks --- .../ScheduledTasks/TaskManager.cs | 49 +++++++--------------- 1 file changed, 16 insertions(+), 33 deletions(-) (limited to 'Emby.Server.Implementations/ScheduledTasks/TaskManager.cs') diff --git a/Emby.Server.Implementations/ScheduledTasks/TaskManager.cs b/Emby.Server.Implementations/ScheduledTasks/TaskManager.cs index 42c30c959..a5e4104ff 100644 --- a/Emby.Server.Implementations/ScheduledTasks/TaskManager.cs +++ b/Emby.Server.Implementations/ScheduledTasks/TaskManager.cs @@ -1,5 +1,3 @@ -#pragma warning disable CS1591 - using System; using System.Collections.Concurrent; using System.Collections.Generic; @@ -41,21 +39,16 @@ namespace Emby.Server.Implementations.ScheduledTasks ScheduledTasks = Array.Empty(); } + /// public event EventHandler>? TaskExecuting; + /// public event EventHandler? TaskCompleted; - /// - /// Gets the list of Scheduled Tasks. - /// - /// The scheduled tasks. - public IScheduledTaskWorker[] ScheduledTasks { get; private set; } + /// + public IReadOnlyList ScheduledTasks { get; private set; } - /// - /// Cancels if running and queue. - /// - /// The task type. - /// Task options. + /// public void CancelIfRunningAndQueue(TaskOptions options) where T : IScheduledTask { @@ -65,16 +58,14 @@ namespace Emby.Server.Implementations.ScheduledTasks QueueScheduledTask(options); } + /// public void CancelIfRunningAndQueue() where T : IScheduledTask { CancelIfRunningAndQueue(new TaskOptions()); } - /// - /// Cancels if running. - /// - /// The task type. + /// public void CancelIfRunning() where T : IScheduledTask { @@ -82,11 +73,7 @@ namespace Emby.Server.Implementations.ScheduledTasks ((ScheduledTaskWorker)task).CancelIfRunning(); } - /// - /// Queues the scheduled task. - /// - /// The task type. - /// Task options. + /// public void QueueScheduledTask(TaskOptions options) where T : IScheduledTask { @@ -102,12 +89,14 @@ namespace Emby.Server.Implementations.ScheduledTasks } } + /// public void QueueScheduledTask() where T : IScheduledTask { QueueScheduledTask(new TaskOptions()); } + /// public void QueueIfNotRunning() where T : IScheduledTask { @@ -119,6 +108,7 @@ namespace Emby.Server.Implementations.ScheduledTasks } } + /// public void Execute() where T : IScheduledTask { @@ -144,11 +134,7 @@ namespace Emby.Server.Implementations.ScheduledTasks } } - /// - /// Queues the scheduled task. - /// - /// The task. - /// The task options. + /// public void QueueScheduledTask(IScheduledTask task, TaskOptions options) { var scheduledTask = ScheduledTasks.FirstOrDefault(t => t.ScheduledTask.GetType() == task.GetType()); @@ -186,10 +172,7 @@ namespace Emby.Server.Implementations.ScheduledTasks } } - /// - /// Adds the tasks. - /// - /// The tasks. + /// public void AddTasks(IEnumerable tasks) { var list = tasks.Select(t => new ScheduledTaskWorker(t, _applicationPaths, this, _logger)); @@ -197,9 +180,7 @@ namespace Emby.Server.Implementations.ScheduledTasks ScheduledTasks = ScheduledTasks.Concat(list).ToArray(); } - /// - /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources. - /// + /// public void Dispose() { Dispose(true); @@ -218,11 +199,13 @@ namespace Emby.Server.Implementations.ScheduledTasks } } + /// public void Cancel(IScheduledTaskWorker task) { ((ScheduledTaskWorker)task).Cancel(); } + /// public Task Execute(IScheduledTaskWorker task, TaskOptions options) { return ((ScheduledTaskWorker)task).Execute(options); -- cgit v1.2.3