TPL异步并行编程之简单使用
在上篇随笔里面说明了Task的使用，仅仅是简单使用，有时候把一个任务交给Task去执行，但是呢还是要管理下，比如说：我要叫这个任务停止了，不做了，任务取消了，或者超时了
在传统的While里面我们可以这样做，1 通过标识 2 通过一个方法抛异常，3 其他办法
举个例子：while(true){
if(isNotCancel){
//每次都判断下，取消没有，当然isNotCancel需要加上lock的
}
}
难道在Task里面有什么新奇吗？其实也没啥新奇的，那Task怎么取消呢？来点干货吧
一 轮训检测
直接调用task.cancel方法，但是下Task函数体内部必须做轮训检测是否被取消，且看代码
1 static void Main(string[] args) 2 { 3 CancellationTokenSource tokenSource = new CancellationTokenSource(); 4 5 CancellationToken token = tokenSource.Token; 6 7 Task task=new Task(() => 8 { 9 while (true) 10 { 11 if (token.IsCancellationRequested) 12 { 13 break; 14 } 15 else 16 { 17 18 } 19 } 20 },token); 21 22 23 Console.WriteLine("运行"); 24 25 26 27 task.Start(); 28 29 Thread.Sleep(5*1000); 30 31 tokenSource.Cancel(); 32 33 Console.ReadKey(); 34 }
二 取消过程拦截检测
在调用task.cancel方法是会在真正改变token.IsCancellationRequested值之前，调用token中所注册的函数，也就是说token.cancel(),调用后会调用token.register所注册的方法，然后再更改token.IsCancellationRequested只为true，那么反过来在注册的方法中我们就可以检测是否调用了cancel方法了也就自然检测到了已经取消了
且看代码说话：
1 static void Main(string[] args) 2 { 3 CancellationTokenSource tokenSource = new CancellationTokenSource(); 4 5 CancellationToken token = tokenSource.Token; 6 7 Task task=new Task(() => 8 { 9 while (true) 10 { 11 if (token.IsCancellationRequested) 12 { 13 break; 14 } 15 else 16 { 17 18 } 19 } 20 },token); 21 22 23 Console.WriteLine("运行"); 24 25 token.Register(() => 26 { 27 Console.WriteLine("取消了，在取消之前必定调用了我"); 28 }); 29 30 task.Start(); 31 32 Thread.Sleep(5*1000); 33 34 tokenSource.Cancel(); 35 36 Console.ReadKey(); 37 }
三 使用信号量来检测是否取消
现在我们启用2个Task，TaskA，TaskB，TaskB需要TaskA取消后才能执行，那么我们也可以在TaskB中执行代码时检测TaskA已被取消了，且看代码
1 static void Main(string[] args) 2 { 3 CancellationTokenSource tokenSource = new CancellationTokenSource(); 4 5 CancellationToken token = tokenSource.Token; 6 7 Task task=new Task(() => 8 { 9 while (true) 10 { 11 // 一直在运行,下面那个家伙得等着我被取消或者把事情做完 12 if (token.IsCancellationRequested) 13 { 14 //我已被取消该时候退出了 15 break; 16 } 17 } 18 },token); 19 20 21 Task.Run(() => 22 { 23 //我一开始就被上面那个task家伙挂起了，我需要他取消我才能干活~~ 24 token.WaitHandle.WaitOne(); 25 while (true) 26 { 27 // 开始干活 28 } 29 }); 30 31 task.Start(); 32 33 Thread.Sleep(5*1000); 34 35 tokenSource.Cancel(); 36 37 Console.ReadKey(); 38 }
四 多个协作的Task一个取消则其他Task也被取消，这样也可以取消一组Task
就好比我们几个人一起干一件事情，但是这件事情需要每个分工的相互协作才能继续，比如玉女双休剑，需要2人同时练功才行，其中一个人说我不行了 那都不行了，且看代码
4.1 共用一个Token
1 static void Main(string[] args) 2 { 3 CancellationTokenSource tokenSource = new CancellationTokenSource(); 4 5 // create the cancellation token 6 CancellationToken token = tokenSource.Token; 7 8 // create the tasks 9 Task task1 = new Task(() => 10 { 11 for (int i = 0; i < int.MaxValue; i++) 12 { 13 token.ThrowIfCancellationRequested(); 14 Console.WriteLine("Task 1 - Int value {0}", i); 15 } 16 }, token); 17 18 Task task2 = new Task(() => 19 { 20 for (int i = 0; i < int.MaxValue; i++) 21 { 22 token.ThrowIfCancellationRequested(); 23 Console.WriteLine("Task 2 - Int value {0}", i); 24 } 25 }, token); 26 // wait for input before we start the tasks 27 Console.WriteLine("Press enter to start tasks"); 28 Console.WriteLine("Press enter again to cancel tasks"); 29 Console.ReadLine(); 30 31 // start the tasks 32 task1.Start(); 33 task2.Start(); 34 35 // read a line from the console. 36 Console.ReadLine(); 37 38 // cancel the task 39 Console.WriteLine("Cancelling tasks"); 40 tokenSource.Cancel(); 41 // wait for input before exiting 42 Console.WriteLine("Main method complete. Press enter to finish."); 43 Console.ReadLine(); 44 }
4.2 Token组
1 static void Main(string[] args) 2 { 3 // create the cancellation token sources 4 CancellationTokenSource tokenSource1 = new CancellationTokenSource(); 5 CancellationTokenSource tokenSource2 = new CancellationTokenSource(); 6 CancellationTokenSource tokenSource3 = new CancellationTokenSource(); 7 8 // create a composite token source using multiple tokens 9 CancellationTokenSource compositeSource = 10 CancellationTokenSource.CreateLinkedTokenSource( 11 tokenSource1.Token, tokenSource2.Token, tokenSource3.Token); 12 13 // create a cancellable task using the composite token 14 Task task = new Task(() => 15 { 16 // wait until the token has been cancelled 17 compositeSource.Token.WaitHandle.WaitOne(); 18 // throw a cancellation exception 19 throw new OperationCanceledException(compositeSource.Token); 20 }, compositeSource.Token); 21 22 // start the task 23 task.Start(); 24 25 // cancel one of the original tokens 26 Thread.Sleep(2*1000); 27 tokenSource2.Cancel(); 28 29 // wait for input before exiting 30 Console.WriteLine("Main method complete. Press enter to finish."); 31 Console.ReadLine(); 32 }
五 抛出异常
ThrowIfCancellationRequested，在四中已经看到如果调用cancel方法会处罚ThrowIfCancellationRequested函数的执行，那么相应的Task检测到异常如果不做任何处理的情况下也就退出了，且看代码
1 代码 2 3 Code highlighting produced by Actipro CodeHighlighter (freeware)http://www.CodeHighlighter.com/--> static void Main(string[] args) 4 { 5 // create the cancellation token source 6 CancellationTokenSource tokenSource1 = new CancellationTokenSource(); 7 8 // create the cancellation token 9 CancellationToken token1 = tokenSource1.Token; 10 11 // create the first task, which we will let run fully 12 Task task1 = new Task(() => 13 { 14 for (int i = 0; i < 10; i++) 15 { 16 token1.ThrowIfCancellationRequested(); 17 Console.WriteLine("Task 1 - Int value {0}", i); 18 } 19 }, token1); 20 21 // create the second cancellation token source 22 CancellationTokenSource tokenSource2 = new CancellationTokenSource(); 23 24 // create the cancellation token 25 CancellationToken token2 = tokenSource2.Token; 26 27 // create the second task, which we will cancel 28 Task task2 = new Task(() => 29 { 30 for (int i = 0; i < int.MaxValue; i++) 31 { 32 token2.ThrowIfCancellationRequested(); 33 Console.WriteLine("Task 2 - Int value {0}", i); 34 } 35 }, token2); 36 37 // start all of the tasks 38 task1.Start(); 39 task2.Start(); 40 41 // cancel the second token source 42 tokenSource2.Cancel(); 43 // write out the cancellation detail of each task 44 Console.WriteLine("Task 1 cancelled? {0}", task1.IsCanceled); 45 Console.WriteLine("Task 2 cancelled? {0}", task2.IsCanceled); 46 // wait for input before exiting 47 Console.WriteLine("Main method complete. Press enter to finish."); 48 Console.ReadLine(); 49 }
最后
其实取消Task的执行还有其他办法，也可以自己实现不一定就要TPL通过的api来实现