TaskCompletionSource设置线程执行状态

鸿翔机器人

简单来说，TaskCompletionSource是一种允许我们创建未绑定Task的类型，这意味着它不与委托绑定。这让您可以手动控制任务完成的时间和方式。您可以手动设置任务的结果，或者发出信号表示任务由于取消或错误而完成。

1.   static async Task demo4()
   
2.   {
   
3.       var result =await  UpLoadFile();
   
4.       Console.WriteLine($"结果是{result}");
   
5. 
   
6.   }
   
7. 
   
8.   static Task<bool> UpLoadFile()
   
9.   {
   
10.       var source = new TaskCompletionSource<bool>();
    
11.       try
    
12.       {
    
13.           Task.Run(async () =>
    
14.           {
    
15.               Console.WriteLine($"开始下载");
    
16.               await Task.Delay(5000);
    
17.               Console.WriteLine($"完成下载");
    
18.               //设置成功
    
19.               source.SetResult( true );
    
20.           });
    
21.       }
    
22.       catch (Exception ex)
    
23.       {
    
24.           //设置失败
    
25.           source.SetResult(false);
    
26.       }
    
27.       return source.Task;
    
28.   }
    
29. 
    

复制代码

TaskCompletionSource 还可以用于实现任务的暂停和恢复。通过手动控制任务的完成状态，我们可以在特定条件下暂停任务，并在条件满足时恢复任务。我们使用 TaskCompletionSource 来实现任务的暂停和恢复。当用户按下任意键时，任务将从暂停状态恢复并继续执行。

1. using System;
   
2. using System.Threading.Tasks;
   
3. 
   
4. public class PauseExample
   
5. {
   
6.     private static TaskCompletionSource<bool> _pauseTcs;
   
7. 
   
8.     public static async Task Main(string[] args)
   
9.     {
   
10.         _pauseTcs = new TaskCompletionSource<bool>();
    
11. 
    
12.         Task longRunningTask = LongRunningOperationAsync();
    
13. 
    
14.         Console.WriteLine("按任意键继续...");
    
15.         Console.ReadKey();
    
16.         _pauseTcs.SetResult(true); // 恢复任务
    
17. 
    
18.         await longRunningTask;
    
19.         Console.WriteLine("任务完成!");
    
20.     }
    
21. 
    
22.     public static async Task LongRunningOperationAsync()
    
23.     {
    
24.         Console.WriteLine("任务开始...");
    
25. 
    
26.         await _pauseTcs.Task; // 等待任务恢复
    
27. 
    
28.         Console.WriteLine("任务恢复，继续执行...");
    
29.         // 模拟更多工作
    
30.         await Task.Delay(2000);
    
31. 
    
32.         Console.WriteLine("任务结束。");
    
33.     }
    
34. }
    
35. 
    
36. 
    

复制代码