0

0

c# 自定义 TaskScheduler 的使用场景和实现方法

月夜之吻

月夜之吻

发布时间:2026-01-21 08:23:02

|

714人浏览过

|

来源于php中文网

原创

必须自定义TaskScheduler的场景包括:需控制线程来源、执行顺序、优先级、取消传播,或深度集成UI线程/WPF Dispatcher/游戏主循环等单线程上下文;典型信号有跨线程访问异常、需严格串行执行、任务插队、单元测试需步进执行。

c# 自定义 taskscheduler 的使用场景和实现方法

什么时候必须自己写 TaskScheduler

系统默认的 ThreadPoolTaskScheduler(即 Task.Runnew 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 类后,至少要重写两个成员:QueueTaskGetScheduledTasks(后者仅用于调试/诊断,可抛 NotSupportedException)。关键不是“怎么跑任务”,而是“谁来跑、何时跑、在哪跑”。

常见实现模式:

  • 单线程调度器:内部维护一个 ConcurrentQueue,靠一个长期存活的线程(或 Thread.Start() 启动)持续 TryDequeuebase.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 误判):

BEES企业网站管理系统3.4
BEES企业网站管理系统3.4

主要特性: 1、支持多种语言 BEES支持多种语言,后台添加自动生成,可为每种语言分配网站风格。 2、功能强大灵活 BEES除内置的文章、产品等模型外,还可以自定义生成其它模型,满足不同的需求 3、自定义表单系统 BEES可自定义表单系统,后台按需要生成,将生成的标签加到模板中便可使用。 4、模板制作方便 采用MVC设计模式实现了程序与模板完全分离,分别适合美工和程序员使用。 5、用户体验好 前台

下载
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.StartNewTask.Schedule(.NET 6+)

容易踩的坑和性能提醒

自定义 TaskScheduler 不是“换个线程跑任务”那么简单,几个高频问题:

  • TryExecuteTask 返回 false 表示任务已执行完毕或已被取消——如果忽略返回值,可能重复执行或静默失败
  • QueueTask 里直接调用 task.Start() 会绕过调度器自身逻辑,导致状态混乱、异常未被捕获
  • 单线程调度器若任务中发生阻塞(如 Thread.SleepTask.Wait()),整个队列会被卡住——务必确保任务是异步友好的
  • .NET 5+ 引入了 TaskScheduler.Default 的缓存优化,但自定义调度器不会参与该优化,频繁创建新实例有开销
  • 调试时,GetScheduledTasks 若没实现,Visual Studio 的“并行任务窗口”看不到你的任务——但不影响运行

最常被忽略的一点:调度器本身不管理生命周期。如果你的调度器依赖某个 ControlDispatcher,它被释放后你还往里扔任务,就会崩溃或静默丢弃——务必配合 IDisposable 和空引用防护。

相关专题

更多
线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

482

2023.08.10

Java 并发编程高级实践
Java 并发编程高级实践

本专题深入讲解 Java 在高并发开发中的核心技术,涵盖线程模型、Thread 与 Runnable、Lock 与 synchronized、原子类、并发容器、线程池(Executor 框架)、阻塞队列、并发工具类(CountDownLatch、Semaphore)、以及高并发系统设计中的关键策略。通过实战案例帮助学习者全面掌握构建高性能并发应用的工程能力。

61

2025.12.01

default gateway怎么配置
default gateway怎么配置

配置default gateway的步骤:1、了解网络环境;2、获取路由器IP地址;3、登录路由器管理界面;4、找到并配置WAN口设置;5、配置默认网关;6、保存设置并退出;7、检查网络连接是否正常。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

220

2023.12.07

vb中怎么连接access数据库
vb中怎么连接access数据库

vb中连接access数据库的步骤包括引用必要的命名空间、创建连接字符串、创建连接对象、打开连接、执行SQL语句和关闭连接。本专题为大家提供连接access数据库相关的文章、下载、课程内容,供大家免费下载体验。

324

2023.10.09

vb连接access数据库的方法
vb连接access数据库的方法

vb连接access数据库方法:1、使用ADO连接,首先导入System.Data.OleDb模块,然后定义一个连接字符串,接着创建一个OleDbConnection对象并使用Open() 方法打开连接;2、使用DAO连接,首先导入 Microsoft.Jet.OLEDB模块,然后定义一个连接字符串,接着创建一个JetConnection对象并使用Open()方法打开连接即可。

401

2023.10.16

asp连接access数据库的方法
asp连接access数据库的方法

连接的方法:1、使用ADO连接数据库;2、使用DSN连接数据库;3、使用连接字符串连接数据库。想了解更详细的asp连接access数据库的方法,可以阅读本专题下面的文章。

120

2023.10.18

access和trunk端口的区别
access和trunk端口的区别

access和trunk端口的区别是Access端口用于连接终端设备,提供单个VLAN的接入,而Trunk端口用于连接交换机之间,提供多个VLAN的传输;Access端口只传输属于指定VLAN的数据,而Trunk端口可以传输多个VLAN的数据,并使用VLAN标签进行区分。想了解更多access和trunk端口相关内容,可以阅读本专题下面的文章。

329

2023.10.31

access怎么导入数据
access怎么导入数据

access导入数据步骤:1. 选择数据源 2. 选择要导入的文件 3. 指定导入选项 4. 选择导入目标 5. 预览数据 6. 导入数据即可。想了解更多access的相关内容,可以阅读本专题下面的文章。

440

2024.04.10

excel表格操作技巧大全 表格制作excel教程
excel表格操作技巧大全 表格制作excel教程

Excel表格操作的核心技巧在于 熟练使用快捷键、数据处理函数及视图工具,如Ctrl+C/V(复制粘贴)、Alt+=(自动求和)、条件格式、数据验证及数据透视表。掌握这些可大幅提升数据分析与办公效率,实现快速录入、查找、筛选和汇总。

0

2026.01.21

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
PostgreSQL 教程
PostgreSQL 教程

共48课时 | 7.5万人学习

Excel 教程
Excel 教程

共162课时 | 12.6万人学习

PHP基础入门课程
PHP基础入门课程

共33课时 | 2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号