c#

C# taskscheduler如何实现任务的动态添加

小樊
91
2024-10-16 19:24:23
栏目: 编程语言

在C#中,使用TaskScheduler类可以轻松地安排和执行任务。要实现任务的动态添加,你可以创建一个自定义的TaskScheduler类,该类继承自TaskScheduler并重写QueueTask方法。这样,你可以在运行时根据需要动态地添加任务。

以下是一个简单的示例,展示了如何创建一个自定义的TaskScheduler类并动态添加任务:

using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;

class CustomTaskScheduler : TaskScheduler
{
    private readonly ConcurrentQueue<Task> _tasks = new ConcurrentQueue<Task>();

    protected override IEnumerable<Task> GetScheduledTasks()
    {
        return _tasks;
    }

    protected override void QueueTask(Task task)
    {
        _tasks.Enqueue(task);
        base.QueueTask(task);
    }

    public void AddTask(Action action, TimeSpan delay)
    {
        var task = new Task(action);
        task.Delay(delay);
        AddTask(task);
    }
}

class Program
{
    static void Main(string[] args)
    {
        var customTaskScheduler = new CustomTaskScheduler();

        // 动态添加任务
        customTaskScheduler.AddTask(() => Console.WriteLine("Task 1 executed at: " + DateTime.Now), TimeSpan.FromSeconds(2));
        customTaskScheduler.AddTask(() => Console.WriteLine("Task 2 executed at: " + DateTime.Now), TimeSpan.FromSeconds(4));

        // 等待所有任务完成
        Task.WaitAll(customTaskScheduler.GetScheduledTasks().ToArray());
    }
}

在这个示例中,我们创建了一个名为CustomTaskScheduler的自定义TaskScheduler类。这个类使用ConcurrentQueue<Task>来存储计划任务。AddTask方法接受一个Action和一个TimeSpan延迟,然后创建一个新的Task实例,将其添加到队列中,并调用基类的QueueTask方法来安排任务。

Main方法中,我们创建了一个CustomTaskScheduler实例,并使用AddTask方法动态添加了两个任务。这些任务将在指定的延迟后执行。最后,我们使用Task.WaitAll等待所有任务完成。

0
看了该问题的人还看了