.Net中异步任务的取消和监控的具体实现
相关类型:
- CancellationTokenSource 主要用来创建或取消令牌
- CancellationToken 监听令牌状态,注册令牌取消事件
- OperationCanceledException 令牌被取消时抛出的异常,可以由监听者自主决定是否抛出异常
CancellationTokenSource
创建令牌:
CancellationTokenSource cts = new CancellationTokenSource() CancellationToken token=cts.Token;
取消释放令牌:
cts.Cancel();
CancellationToken
监听令牌取消事件:
token.Register(() => Console.WriteLine("令牌被取消"));
判断令牌是否取消
//返回一个bool,如果令牌被取消为true token.IsCancellationRequested //如果token被取消则抛出异常,内部实现其实就是判断IsCancellationRequested token.ThrowIfCancellationRequested()=>{ if(token.IsCancellationRequested){ throw new OperationCanceledException(); } }
代码示例
下面模拟一个文件下载的任务,在未下载完成后下载任务被取消
public void Run() { CancellationTokenSource cts = new CancellationTokenSource(); Task.Run(() => { //等待两秒后取消,模拟的是用户主动取消下载任务 Thread.Sleep(2000); cts.Cancel(); }); try { var size = DownloadFile(cts.Token); Console.WriteLine("文件大小:" + size); } catch (OperationCanceledException) { Console.WriteLine("下载失败"); }finally{ cts.Dispose(); } Thread.Sleep(2000); } /// <summary> /// 模拟下载文件,下载文件需要五秒 /// </summary> /// <returns></returns> public int DownloadFile(CancellationToken token) { token.Register(() => { System.Console.WriteLine("监听到取消事件"); }); Console.WriteLine("开始下载文件"); for (int i = 0; i < 5; i++) { token.ThrowIfCancellationRequested(); Console.WriteLine(i.ToString()); Thread.Sleep(1000); } Console.WriteLine("文件下载完成"); return 100; }
输出结果:
开始下载文件
0
1
监听到取消事件
下载失败
思考
为什么要将CancellationToken和CancellationTokenSource分为两个类呢,直接一个CancellationToken又可以取消又可以判断状态注册啥的不是更好,更方便?
其实每种类的设计和实现都可以有很多不同的策略,CTS和CT从这个两个类提供的为数不多的公开方法中就可以看出,CTS用来控制Token的生成和取消等生命周期状态,CT只能用来监听和判断,无法对Token的状态进行改变。
所以这种设计的目的就是关注点分离。限制了CT的功能,避免Token在传递过程中被不可控的因素取消造成混乱。
关联令牌
继续拿上面的示例来说,示例中实现了从外部控制文件下载功能的终止。
如果要给文件下载功能加一个超时时间的限制,此时可以增加一个控制超时时间的token,将外部传来的token和内部token 关联起来变为一个token
只需要将DownloadFile()函数做如下改造即可
public int DownloadFile(CancellationToken externalToken) { //通过构造函数设置TokenSource一秒之后调用Cancel()函数 var timeOutToken = new CancellationTokenSource(new TimeSpan(0, 0, 1)).Token; using (var linkToken = CancellationTokenSource.CreateLinkedTokenSource(externalToken, timeOutToken)) { Console.WriteLine("开始下载文件"); for (int i = 0; i < 5; i++) { linkToken.Token.ThrowIfCancellationRequested(); Console.WriteLine(i.ToString()); Thread.Sleep(1000); } Console.WriteLine("文件下载完成"); return 100; } }
此时不论是externalToken取消,或是timeOutToken取消,都会触发linkToken的取消事件
CancellationChangeToken
CancellationChangeToken主要用来监测目标变化,需配合ChangeToken使用。从功能场景来说,其实ChangeToken的功能和事件似乎差不多,当监控的目标发生了变化,监听者去做一系列的事情。
但是事件的话,监听者需要知道目标的存在,就是如果A要注册B的事件,A是要依赖B的。
CancellationChangeToken是基于CancellationToken来实现的,可以做到依赖于Token而不直接依赖被监听的类
创建CancellationChangeToken:
new CancellationChangeToken(new CancellationTokenSource().Token)
监听Token变动
new CancellationChangeToken(cts.Token).RegisterChangeCallback(obj => Console.WriteLine("token 变动"), null);
CancellationChangeToken只是把CancellationToken包装了一层。RegisterChangeCallback最终也是监听的CancellationToken的IsCancellationRequested状态。
所以就有个问题,代码写到这里,并不能实现每次内部变动都触发回调事件。
因为CT只会Cancel一次,对应的监听也会执行一次。无法实现多次监听
为了实现变化的持续监听,需要做两个操作
- 让Token在Cancel之后重新初始化
- 每次Cancel回调之后重新监听新的Token
先上代码,下面的代码实现了每次时间变动都会通知展示面板刷新时间的显示
public void Run() { var bjDate = new BeijingDate(); DisplayDate(bjDate.GetChangeToken, bjDate.GetDate); Thread.Sleep(50000); } public void DisplayDate(Func<IChangeToken> getChangeToken, Func<DateTime> getDate) { ChangeToken.OnChange(getChangeToken, () => Console.WriteLine("当前时间:" + getDate())); } public class BeijingDate { private CancellationTokenSource cts; private DateTime date; public BeijingDate() { cts = new CancellationTokenSource(); var timer = new Timer(TimeChange, null, 0, 1000); } private void TimeChange(object state) { date = DateTime.Now; var old = cts; cts = new CancellationTokenSource(); old.Cancel(); } public DateTime GetDate() => date; public CancellationChangeToken GetChangeToken() { return new CancellationChangeToken(cts.Token); } }
在TimeChange()中修改了时间,重置了Token并将旧的Token取消
在DisplayDate中用ChangeToken.OnChange获取对应的Token并监听
实现了DisplayData函数和BeijingDate这个类的解耦
ChangeToken.OnChange 这个函数接收两个参数,一个是获取Token的委托,一个是Token取消事件的响应委托。
每次在处理完Token的取消事件后,他会重新调用第一个委托获取Token,而此时我们已经生成了新的Token,最终实现了持续监控
到此这篇关于.Net中异步任务的取消和监控的文章就介绍到这了,更多相关.Net中异步任务的取消和监控内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞!
相关文章
- 这篇文章主要为大家详细介绍了ASP.NET购物车的实现过程,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-09-22
- 这篇文章主要介绍了.NET Core下使用Kafka的方法步骤,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-09-22
- 在开发过程中,使用Visual Studio的断点调试功能可以很方便帮我们调试发现程序存在的错误,同样Visual Studio也支持对SQL Server里面的存储过程进行调试,下面就让我们看看具体的调试方法。...2021-09-22
- 这篇文章主要介绍了Win10 IIS 安装及.net 4.5及Win10安装IIS并配置ASP.NET 4.0的方法,本文给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下...2021-09-22
- 这篇文章主要介绍了详解.NET Core 3.0 里新的JSON API,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-09-22
- 这篇文章主要介绍了.net数据库操作框架SqlSugar的简单入门,帮助大家更好的理解和学习使用.net技术,感兴趣的朋友可以了解下...2021-09-22
ASP.NET Core根据环境变量支持多个 appsettings.json配置文件
这篇文章主要介绍了ASP.NET Core根据环境变量支持多个 appsettings.json配置文件,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-09-22- 这篇文章主要介绍了记一次EFCore类型转换错误及解决方案,帮助大家更好的理解和学习使用asp.net core,感兴趣的朋友可以了解下...2021-09-22
- 这篇文章主要介绍了C#中异步和多线程的相关资料,帮助大家更好的理解和学习c#,感兴趣的朋友可以了解下...2021-01-16
- 多线程和异步操作两者都可以达到避免调用线程阻塞的目的,从而提高软件的可响应性。甚至有些时候我们就认为多线程和异步操作是等同的概念。但是,多线程和异步操作还是有一些区别的。而这些区别造成了使用多线程和异步操作的时机的区别...2020-06-25
- 本篇文章主要介绍了C# Socket异步通信,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧...2020-06-25
C#使用FileSystemWatcher控件实现的文件监控功能示例
这篇文章主要介绍了C#使用FileSystemWatcher控件实现的文件监控功能,结合实例形式分析了C# FileSystemWatcher组件的功能及监控文件更改情况的具体使用技巧,需要的朋友可以参考下...2020-06-25- 这篇文章主要给大家介绍了关于JS异步的执行原理和回调的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-03-08
percona-toolkit对MySQL的复制和监控类操作教程
复制类工具 1. pt-heartbeat 功能介绍: 监控mysql复制延迟 用法介绍: pt-heartbeat [OPTION...] [DSN] --update|--monitor|--check|--stop 测量复制落后主mysql或者主PostgreSQL多少时间,你可以使用这个脚本去更新主或...2015-11-24- 这篇文章主要介绍了JQuery基于FormData异步提交数据文件,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下...2020-09-02
- 这篇文章主要给大家介绍了关于c# winform异步不卡界面的实现方法,文中通过示例代码介绍的非常详细,对大家学习或者使用c#具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧...2020-06-25
- 这篇文章主要介绍了C#实现简单屏幕监控的方法,涉及C#的图标隐藏及屏幕截图等技巧,具有一定参考借鉴价值,需要的朋友可以参考下...2020-06-25
- ZXing是一个开放源码的,用Java实现的多种格式的1D/2D条码图像处理库,它包含了联系到其他语言的端口。这篇文章主要给大家介绍了.NET C#利用ZXing生成、识别二维码/条形码的方法,文中给出了详细的示例代码,有需要的朋友们可以参考借鉴。...2020-06-25
详解ASP.NET Core 中基于工厂的中间件激活的实现方法
这篇文章主要介绍了ASP.NET Core 中基于工厂的中间件激活的实现方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2021-09-22- 这篇文章主要介绍了解决druid监控页面SQL不显示的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-06-19