怎样用C# taskscheduler管理多个任务 - 问答

在C#中，使用TaskScheduler类可以方便地管理和调度多个任务。以下是一个简单的示例，展示了如何使用TaskScheduler来创建、调度和执行多个任务：

首先，确保已经安装了System.Threading.Tasks命名空间。如果没有安装，可以通过NuGet包管理器进行安装。
创建一个继承自TaskScheduler的类，以便可以添加自定义逻辑。在这个示例中，我们将创建一个简单的MyTaskScheduler类。

using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;

public class MyTaskScheduler : TaskScheduler
{
    private readonly List<Task> _tasks = new List<Task>();

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

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

    public void Start()
    {
        foreach (var task in _tasks)
        {
            Task.Run(() => task.Run());
        }
    }
}

在这个示例中，我们创建了一个MyTaskScheduler类，它继承自TaskScheduler。我们添加了一个_tasks列表来存储调度任务，并重写了GetScheduledTasks和QueueTask方法以便访问这些任务。我们还添加了一个Start方法，用于启动所有调度任务。

创建一个要执行的任务类。在这个示例中，我们将创建一个简单的MyTask类，它实现IRunnable接口。

public interface IRunnable
{
    void Run();
}

public class MyTask : IRunnable
{
    private readonly string _name;

    public MyTask(string name)
    {
        _name = name;
    }

    public void Run()
    {
        Console.WriteLine($"Starting task: {_name}");
        Thread.Sleep(1000); // 模拟任务执行时间
        Console.WriteLine($"Finished task: {_name}");
    }
}

在这个示例中，我们创建了一个MyTask类，它实现IRunnable接口。Run方法用于执行任务逻辑。

使用MyTaskScheduler类调度和执行多个任务。

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

        var tasks = new List<IRunnable>
        {
            new MyTask("Task 1"),
            new MyTask("Task 2"),
            new MyTask("Task 3")
        };

        foreach (var task in tasks)
        {
            var t = Task.Factory.StartNew(task, CancellationToken.None, TaskCreationOptions.None, taskScheduler);
            t.ContinueWith(_ => Console.WriteLine($"Task completed: {t.Result._name}"));
        }

        taskScheduler.Start();
    }
}

在这个示例中，我们创建了一个MyTaskScheduler实例，并创建了一个IRunnable任务列表。然后，我们遍历任务列表，为每个任务创建一个新的Task实例，并将其添加到MyTaskScheduler中。最后，我们调用taskScheduler.Start()方法来启动所有调度任务。

这个示例展示了如何使用TaskScheduler类来管理和调度多个任务。你可以根据需要扩展这个示例，以适应你的具体需求。

0 赞

0 踩