c# 自定义 TaskScheduler 的使用场景和实现方法
必须自定义TaskScheduler的场景包括：需控制线程来源、执行顺序、优先级、取消传播，或深度集成UI线程/WPF Dispatcher/游戏主循环等单线程上下文；典型信号有跨线程访问异常、需严格串行执行、任务插队、单元测试需步进执行。
什么时候必须自己写 TaskScheduler
系统默认的 ThreadPoolTaskScheduler（即 Task.Run 和 new Task(...).Start() 背后用的那个）在绝大多数场景下够用，但一旦你需要控制任务执行的线程来源、执行顺序、优先级、取消传播方式，或要和已有单线程上下文（比如 WinForms UI 线程、WPF Dispatcher、游戏主循环、嵌入式事件循环）深度集成，就必须自定义 TaskScheduler。
典型信号：
- 你收到
InvalidOperationException: "The calling thread cannot access this object because a different thread owns it."，又不想总用Invoke包裹逻辑 - 需要保证一组任务严格串行执行，且不能被线程池线程抢占（比如操作共享硬件句柄）
- 想给某些任务插队（高优先级任务立即执行），而默认调度器只按入队顺序 FIFO
- 做单元测试时，要“冻结时间”或“逐个步进执行任务”，避免异步不可控
TaskScheduler 的核心实现要点
继承 TaskScheduler 类后，至少要重写两个成员：QueueTask 和 GetScheduledTasks（后者仅用于调试/诊断，可抛 NotSupportedException）。关键不是“怎么跑任务”，而是“谁来跑、何时跑、在哪跑”。
常见实现模式：
-
单线程调度器：内部维护一个
ConcurrentQueue，靠一个长期存活的线程（或Thread.Start()启动）持续TryDequeue并base.TryExecuteTask -
同步调度器（Immediate）：
QueueTask中直接调用base.TryExecuteTask(task)，任务不排队、不异步——适合测试或强制同步上下文 -
UI 线程绑定调度器：在 WinForms 中捕获
Control.InvokeRequired+BeginInvoke；在 WPF 中用Dispatcher.BeginInvoke。注意必须检查是否已在目标线程，否则会死锁
别漏掉这个细节：base.TryExecuteTask(task) 是真正触发任务委托执行并处理异常、状态变更的入口，不能跳过，也不能用 task.Start() 替代。
一个轻量 WinForms UI 调度器示例
以下是一个安全、可复用的 WinForms TaskScheduler 实现，它自动处理跨线程调用，并支持从 UI 线程内直接调度（避免 InvokeRequired 误判）：
public class WindowsFormsTaskScheduler : TaskScheduler, IDisposable
{
private readonly Control _control;
private readonly SynchronizationContext _context;
public WindowsFormsTaskScheduler(Control control)
{
_control = control ?? throw new ArgumentNullException(nameof(control));
_context = SynchronizationContext.Current ?? new WindowsFormsSynchronizationContext();
}
protected override void QueueTask(Task task)
{
if (_control.IsDisposed || _control.Disposing)
{
TryExecuteTask(task);
return;
}
if (_control.InvokeRequired)
{
_control.BeginInvoke(new Action(() => TryExecuteTask(task)));
}
else
{
TryExecuteTask(task);
}
}
protected override IEnumerablezuojiankuohaophpcnTaskyoujiankuohaophpcn GetScheduledTasks() => throw new NotSupportedException();
protected override void ExecuteTask(Task task) => TryExecuteTask(task);
public void Dispose()
{
// 可选：清理资源
}}
使用时：
- 创建：
var uiScheduler = new WindowsFormsTaskScheduler(this);（this是窗体实例） - 调度任务：
Task.Factory.StartNew(() => { /* UI 操作 */ }, CancellationToken.None, uiScheduler); - 注意：
Task.Run(...)无法指定 scheduler，必须用Task.Factory.StartNew或Task.Schedule（.NET 6+）
容易踩的坑和性能提醒
自定义 TaskScheduler 不是“换个线程跑任务”那么简单，几个高频问题：
-
TryExecuteTask返回false表示任务已执行完毕或已被取消——如果忽略返回值，可能重复执行或静默失败 - 在
QueueTask里直接调用task.Start()会绕过调度器自身逻辑，导致状态混乱、异常未被捕获 - 单线程调度器若任务中发生阻塞（如
Thread.Sleep、Task.Wait()），整个队列会被卡住——务必确保任务是异步友好的 - .NET 5+ 引入了
TaskScheduler.Default的缓存优化，但自定义调度器不会参与该优化，频繁创建新实例有开销 - 调试时，
GetScheduledTasks若没实现，Visual Studio 的“并行任务窗口”看不到你的任务——但不影响运行
最常被忽略的一点：调度器本身不管理生命周期。如果你的调度器依赖某个 Control 或 Dispatcher，它被释放后你还往里扔任务，就会崩溃或静默丢弃——
IDisposable 和空引用防护。
