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方法将任务提交到自定义任务调度器中。每个任务都会打印出它们的任务编号和线程编号。

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

希望能帮助到你！