如何自助建站,重庆技术网站建设,鲜花网站建设教程,上海网站建设口碑好一. 传统的线程取消 所谓的线程取消#xff0c;就是线程正在执行的过程中取消线程任务。 传统的线程取消#xff0c;是通过一个变量来控制#xff0c;但是这种方式#xff0c;在release模式下#xff0c;被优化从cpu高速缓存中读取#xff0c;而不是从内存中读取#xf…一. 传统的线程取消 所谓的线程取消就是线程正在执行的过程中取消线程任务。 传统的线程取消是通过一个变量来控制但是这种方式在release模式下被优化从cpu高速缓存中读取而不是从内存中读取会造成主线程无法执行这一个bug。 1 {2 var isStop false;3 var thread new Thread(() 4 {5 while (!isStop)6 {7 Thread.Sleep(100);8 Console.WriteLine(当前thread{0} 正在运行, Thread.CurrentThread.ManagedThreadId);9 }
10 });
11 thread.Start();
12 Thread.Sleep(1000);
13 isStop true;
14 } PS 通过上面的代码看可以看出来传统模式的线程取消在排除release模式bug的情况下局限性还是很明显的。比如当子线程任务取消的那一刻我想执行另外一项任务我想延时取消一个线程任务线程取消的时候抛异常。 上述这几种情况我们都要借助单独的类来处理。 二. CancellationTokenSource实现任务取消
1. 取消任务的同时触发一个函数 利用Cancel方法、Register注册、source.Token标记取消位来实现。 {CancellationTokenSource source new CancellationTokenSource();//注册一个线程取消后执行的逻辑source.Token.Register(() {//这里执行线程被取消后的业务逻辑.Console.WriteLine(-------------我是线程被取消后的业务逻辑---------------------);});Task.Run(() {while (!source.IsCancellationRequested){Thread.Sleep(100);Console.WriteLine(当前thread{0} 正在运行, Thread.CurrentThread.ManagedThreadId);}}, source.Token);Thread.Sleep(2000);source.Cancel();} 2. 延时取消
线程的延时取消有两种方式 方案一CancelAfter方法。 1 #region 方案一CancelAfter方法2 {3 CancellationTokenSource source new CancellationTokenSource();4 //注册一个线程取消后执行的逻辑5 source.Token.Register(() 6 {7 //这里执行线程被取消后的业务逻辑.8 Console.WriteLine(-------------我是线程被取消后的业务逻辑---------------------);9 });
10
11 Task.Run(()
12 {
13 while (!source.IsCancellationRequested)
14 {
15 Thread.Sleep(100);
16 Console.WriteLine(当前thread{0} 正在运行, Thread.CurrentThread.ManagedThreadId);
17 }
18 }, source.Token);
19
20 Thread.Sleep(2000);
21 //4s后自动取消
22 source.CancelAfter(new TimeSpan(0, 0, 0, 4));
23 }
24 #endregion 方案二CancellationTokenSource构造函数不再需要Cancel方法了。 1 {2 //4s后自动取消3 CancellationTokenSource source new CancellationTokenSource(4000);4 //注册一个线程取消后执行的逻辑5 source.Token.Register(() 6 {7 //这里执行线程被取消后的业务逻辑.8 Console.WriteLine(-------------我是线程被取消后的业务逻辑---------------------);9 });
10
11 Task.Run(()
12 {
13 while (!source.IsCancellationRequested)
14 {
15 Thread.Sleep(100);
16 Console.WriteLine(当前thread{0} 正在运行, Thread.CurrentThread.ManagedThreadId);
17 }
18 }, source.Token);
19
20 Thread.Sleep(2000);
21 } 3. 组合取消 利用CreateLinkedTokenSource构建CancellationTokenSource的组合体其中任何一个体取消则组合体就取消。 {CancellationTokenSource source1 new CancellationTokenSource();//source1.Cancel();CancellationTokenSource source2 new CancellationTokenSource();source2.Cancel();var combineSource CancellationTokenSource.CreateLinkedTokenSource(source1.Token, source2.Token);Console.WriteLine(s1{0} s2{1} s3{2}, source1.IsCancellationRequested,source2.IsCancellationRequested,combineSource.IsCancellationRequested);} 上述代码source1和source2中的任何一个取消combineSource就会被取消。 三. CancellationToken类监控取消 CancellationToken类下ThrowIfCancellationRequested属性等价于if (XXX.IsCancellationRequested){throw new Exception(报错了);} 只要取消就报错。 1 {2 CancellationTokenSource source1 new CancellationTokenSource();3 CancellationTokenSource source2 new CancellationTokenSource();4 var combineSource CancellationTokenSource.CreateLinkedTokenSource(source1.Token, source2.Token);5 source1.Cancel();6 7 //if (combineSource.IsCancellationRequested)8 //{9 // throw new Exception(报错了);
10 //}
11
12 //等价于上面那句话
13 try
14 {
15 combineSource.Token.ThrowIfCancellationRequested();
16 }
17 catch (Exception)
18 {
19 Console.WriteLine(报错了);
20 }
21
22
23 Console.WriteLine(s1{0} s2{1} s3{2}, source1.IsCancellationRequested,
24 source2.IsCancellationRequested,
25 combineSource.IsCancellationRequested);
26 }
