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 里同步等待资源。这些细节，比语法更决定成败。
