C# CancellationTokenSource 令牌取消操作

鸿翔机器人

1.     static void Main(string[] args)
   
2.     {
   
3.         Demo01();
   
4.         Console.ReadLine();
   
5.     }
   
6. 
   
7.     static void Demo01()
   
8.     {
   
9.         //CancellationTokenSource cts = new CancellationTokenSource();
   
10.         //CancellationToken token = cts.Token;
    
11. 
    
12.         CancellationTokenSource cts = new CancellationTokenSource();
    
13.         CancellationTokenSource cts2 = new CancellationTokenSource();
    
14.         CancellationTokenSource linkedCts = CancellationTokenSource.CreateLinkedTokenSource(cts.Token, cts2.Token);
    
15.         CancellationToken token = linkedCts.Token;
    
16. 
    
17.         //CancellationTokenSource被取消时触发
    
18.         token.Register(() => { Console.WriteLine("取消令牌"); });
    
19.         Test(token);
    
20. 
    
21.         //Console.ReadLine();
    
22.         //cts.Cancel();
    
23.         cts2.CancelAfter(1000);
    
24. 
    
25.         Console.ReadLine();
    
26.         cts.Dispose();
    
27.         Console.WriteLine("Demo完成");
    
28. 
    
29.     }
    
30. 
    
31.     static async Task Test(CancellationToken token)
    
32.     {
    
33.         try
    
34.         {
    
35.             Task task = Task.Run(() =>
    
36.             {
    
37.                 Dowork(token);
    
38.             }, token);
    
39. 
    
40.             await task;
    
41.             Console.WriteLine("任务已经正常完成");
    
42.         }
    
43.         catch (OperationCanceledException ex)
    
44.         {
    
45.             Console.WriteLine("任务已经取消");
    
46.         }
    
47.         catch (Exception ex)
    
48.         {
    
49.             Console.WriteLine("任务出错了");
    
50.         }
    
51.     }
    
52. 
    
53.     static void Dowork(CancellationToken token)
    
54.     {
    
55.         int i = 0;
    
56.         while (true)
    
57.         {
    
58.             //token.ThrowIfCancellationRequested();
    
59.             if (i % 1000 == 0)
    
60.             {
    
61.                 if (token.IsCancellationRequested)
    
62.                 {
    
63.                     Console.WriteLine("任务取消退出");
    
64.                     break;
    
65.                 }
    
66. 
    
67.                 Console.WriteLine($"{DateTime.Now}任务正在执行");
    
68.             }
    
69.             //Thread.Sleep(1000);
    
70.             Thread.Sleep(1);
    
71.             i++;
    
72.         }
    
73. 
    
74.         Console.WriteLine("任务终止");
    
75.     }
    
76. }

复制代码