C#怎么实现TaskScheduler任务调度器

在C#中，可以使用System.Threading.Tasks.TaskScheduler类来实现任务调度器。下面是一个示例代码，展示了如何创建和调度任务。

首先，我们需要创建一个继承自TaskScheduler的自定义任务调度器类。在该类中，我们需要重写QueueTask方法来将任务添加到任务队列，并且重写TryExecuteTaskInline方法来执行任务。

using System;using System.Collections.Concurrent;using System.Collections.Generic;using System.Threading;using System.Threading.Tasks;public class CustomTaskScheduler : TaskScheduler{    private BlockingCollection<Task> taskQueue = new BlockingCollection<Task>();    private Thread schedulerThread;    public CustomTaskScheduler()    {        schedulerThread = new Thread(RunScheduler);        schedulerThread.Start();    }    protected override IEnumerable<Task> GetScheduledTasks()    {        return taskQueue.ToArray();    }    protected override void QueueTask(Task task)    {        taskQueue.Add(task);    }    protected override bool TryExecuteTaskInline(Task task, bool taskWasPreviouslyQueued)    {        if (Thread.CurrentThread == schedulerThread)        {            return TryExecuteTask(task);        }        else        {            return false;        }    }    private void RunScheduler()    {        foreach (var task in taskQueue.GetConsumingEnumerable())        {            TryExecuteTask(task);        }    }}

接下来，我们可以使用自定义任务调度器来创建和调度任务。在下面的示例中，我们创建了10个任务，并且使用Task.Factory.StartNew方法将任务提交到自定义任务调度器中。

using System;using System.Threading.Tasks;class Program{    static void Main()    {        CustomTaskScheduler scheduler = new CustomTaskScheduler();        for (int i = 0; i < 10; i++)        {            int taskNumber = i + 1;            Task.Factory.StartNew(() => DoWork(taskNumber), CancellationToken.None, TaskCreationOptions.None, scheduler);        }        Console.ReadKey();    }    static void DoWork(int taskNumber)    {        Console.WriteLine("Task {0} is executing on thread {1}", taskNumber, Thread.CurrentThread.ManagedThreadId);    }}

在上面的代码中，我们创建了10个任务，并且使用Task.Factory.StartNew方法将任务提交到自定义任务调度器中。每个任务都会打印出它们的任务编号和线程编号。

请注意，任务调度器是按顺序调度任务的，因此任务可能会在不同的线程上执行，但它们的顺序是保证的。

希望能帮助到你！