TaskScheduler 是 C# 中控制 Task 执行线程与排队策略的抽象调度器,非定时器;必须继承并实现 QueueTask、TryExecuteTaskInline 和 GetScheduledTasks 三个方法,常见用途包括 UI 线程调度、限流及顺序执行。

TaskScheduler 是 C# 中决定 Task 在哪个线程、何时执行的“调度开关”,不是定时器,也不管“几点跑”,它只管“谁来跑、怎么排队、能不能插队”。默认用的是线程池(TaskScheduler.Default),但你完全可以换掉它——比如让所有任务强制在 UI 线程跑,或限制最多 3 个并发,甚至独占一个后台线程顺序执行。
为什么 不能直接 new TaskScheduler()?
因为 TaskScheduler 是抽象类,必须继承并实现三个核心方法:QueueTask、TryExecuteTaskInline、GetScheduledTasks。漏掉任何一个,编译就报错;实现不对,运行时可能卡死、丢任务、或线程爆炸。
-
QueueTask(Task task):任务进队列的入口,必须把task存起来(比如放进BlockingCollection或ConcurrentQueue) -
TryExecuteTaskInline(Task task, bool taskWasPreviouslyQueued):决定“能不能立刻在当前线程跑”。返回true表示抢跑成功,否则走排队逻辑;UI 调度器常用它判断是否在主线程里,是则直接执行避免跨线程异常 -
GetScheduledTasks():仅用于调试(如 Visual Studio 的“并行任务窗口”),可返回空集合,但不能抛异常或阻塞
最简可用的自定义调度器长什么样?
下面这个调度器只用一个专用线程顺序执行任务,适合需要强顺序、防并发、或隔离资源的场景(比如串口通信、文件写入队列):
public class SingleThreadTaskScheduler : TaskScheduler, IDisposable {private readonly BlockingCollection _taskQueue = new(); private readonly Thread _workerThread; public SingleThreadTaskScheduler() { _workerThread = new Thread(WorkerLoop) {IsBackground = true}; _workerThread.Start();} private void WorkerLoop() { foreach (var task in _taskQueue.GetConsumingEnumerable()) {TryExecuteTask(task); } } protected override void QueueTask(Task task) => _taskQueue.Add(task); protected override bool TryExecuteTaskInline(Task task, bool taskWasPreviouslyQueued) {// 当前线程就是我们的专用线程?允许内联执行 if (Thread.CurrentThread == _workerThread) return TryExecuteTask(task); return false; } protected override IEnumerablezuojiankuohaophpcnTaskyoujiankuohaophpcn GetScheduledTasks() => _taskQueue.ToArray(); public void Dispose() {_taskQueue?.CompleteAdding(); _workerThread?.Join(); _taskQueue?.Dispose(); }
}
⚠️ 注意:没加 IDisposable 和 CompleteAdding(),程序退出时线程会卡住;没判空就调 TryExecuteTask,可能崩在 NullReferenceException。
什么时候该用 FromCurrentSynchronizationContext()?
只在 WPF/WinForms 主线程更新 UI 时才真正需要它。它不是“自定义”,而是 BCL 提供的现成调度器,背后封装了 SynchronizationContext。
- 错误用法:
Task.Run(() => {this.Text = "hello";}, TaskScheduler.FromCurrentSynchronizationContext())——Task.Run默认用线程池,FromCurrentSynchronizationContext()必须在 UI 线程上调用才能捕获上下文,放在线程池里调等于白写 - 正确姿势:在窗体构造或事件处理中(即 UI 线程)获取:
var uiScheduler = TaskScheduler.FromCurrentSynchronizationContext();,再传给Task.Factory.StartNew(……, uiScheduler) - WPF 中如果
TaskScheduler.Current是null,说明当前不在 UI 线程,FromCurrentSynchronizationContext()会返回null,不加判空直接用会 NRE
真正难的不是写调度器,而是想清楚“我到底要控制什么”:是线程亲和性?并发数?执行优先级?还是任务生命周期管理?一旦目标模糊,很容易写出又慢又难 debug 的调度器——比如用 Thread.Sleep 做轮询、用锁暴力保护队列、或在 QueueTask 里同步等待资源。这些细节,比语法更决定成败。