C# 异步方法async / await 任务超时处置惩罚

一、需求

假如调用一个异步方法后，一直不给返回值结果怎么办呢？这就涉及到怎么取消任务了。

二、Task取消任务

1. static CancellationTokenSource source = new CancellationTokenSource();
3. static void Main(string[] args)
4. {
5.      Task.Run(() =>
6.      {
7.          for (int i = 0; i < 10; i++)
8.          {
9.              Thread.Sleep(500);
10.              Console.WriteLine("oh my god");
11.              source.Token.ThrowIfCancellationRequested();
12.          }
13.      }, source.Token);
15.      Thread.Sleep(2000);
16.      Console.WriteLine("取消任务");
17.      source.Cancel();
19.      Console.ReadKey();
22. }

复制代码

换一个写法

2.         static void Main(string[] args)
3.         {
4.             bool isOut = false;
6.             var task1 = Task.Run(() =>
7.             {
8.                 for (int i = 0; i < 100; i++)
9.                 {
10.                     if (isOut) return;
12.                     Console.WriteLine("执行中" + i);
13.                     Thread.Sleep(500);
14.                 }
15.             });
17.             Thread.Sleep(2000);
18.             Console.WriteLine("取消任务");
19.             isOut = true;
21.             Console.ReadKey();
23.         }

复制代码

 我在 for 循环中加入一个判断，假如等于 true，直接跳出循环，这不也可以中断任务

三、Task取消任务的回调

取消任务也是可以加入回调的，如下：

1. static CancellationTokenSource source = new CancellationTokenSource();
3. static void Main(string[] args)
4. {
5.      var task1 = Task.Run(() =>
6.      {
7.          for (int i = 0; i < 100; i++)
8.          {
9.              source.Token.ThrowIfCancellationRequested();
10.              Console.WriteLine("执行中" + i);
11.              Thread.Sleep(500);
12.          }
13.      }, source.Token);
15.      //在指定的毫秒数后取消task执行
16.      source.CancelAfter(2 * 1000);
18.      //取消任务后的回调
19.      source.Token.Register(() =>
20.      {
21.          //不延迟会获取不到正确的状态
22.          Thread.Sleep(50);
23.          Console.WriteLine("task1状态：" + task1.Status);
24.          Console.WriteLine("IsFaulted状态：" + task1.IsFaulted);//由于未处理的异常，任务已完成。
25.          Console.WriteLine("IsCompleted状态：" + task1.IsCompleted);//获取一个值，该值指示任务是否已完成。
26.      });
28.      Console.ReadKey();
30. }

复制代码

四、Task超时处置惩罚的实现


先来一个超时取消后续代码实验的方法

1. private static CancellationTokenSource Cancellation = new CancellationTokenSource();
2. static void Main(string[] args)
3. {
4.      //设置超时的时间
5.      Cancellation.CancelAfter(TimeSpan.FromSeconds(1));
7.      Task.Run(() =>
8.      {
9.          try
10.          {
11.              Console.WriteLine("方法执行开始");
13.              //异步 Task.Delay 可以这么写，await Task.Delay(3000, Cancellation.Token)
14.              //效果同 Cancellation.Token.ThrowIfCancellationRequested()
16.              //await Task.Delay(3000, Cancellation.Token);
17.              Thread.Sleep(2000);
19.              Cancellation.Token.ThrowIfCancellationRequested();
21.              Console.WriteLine("方法执行结束");
22.          }
23.          catch (OperationCanceledException)
24.          {
25.              Console.WriteLine("取消操作");
26.          }
27.      });
29.      Console.ReadKey();
31. }

复制代码

可以看到，方法实验结束这段代码并没有打印，这就是我们想要的结果了，在上面我们设置的超时时间是1秒，在后面的实验中，使用了线程睡眠时间是2秒，超时后，就主动取消操作了


把超时时间改为3秒，看看结果

1. private static CancellationTokenSource Cancellation = new CancellationTokenSource();
2. static void Main(string[] args)
3. {
4.     //设置超时的时间
5.     Cancellation.CancelAfter(TimeSpan.FromSeconds(3));
7.     Task.Run(() =>
8.     {
9.         try
10.         {
11.             Console.WriteLine("方法执行开始");
13.             //异步 Task.Delay 可以这么写，await Task.Delay(3000, Cancellation.Token)
14.             //效果同 Cancellation.Token.ThrowIfCancellationRequested()
16.             //await Task.Delay(3000, Cancellation.Token);
17.             Thread.Sleep(2000);
19.             Cancellation.Token.ThrowIfCancellationRequested();
21.             Console.WriteLine("方法执行结束");
22.         }
23.         catch (OperationCanceledException)
24.         {
25.             Console.WriteLine("取消操作");
26.         }
27.     });
29.     Console.ReadKey();
31. }

复制代码

这回就没有取消任务的实验了，那么超时取消代码实验的结果就实现了。







免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。