按经常的方式管理特别

走进异步编制程序的世界 – 深入分析异步方法(下)

 

  多谢大家的支撑,那是即日发布《走进异步编制程序的世界 –
深入分析异步方法(上)》的补给篇。

 

目录

  • 不行管理
  • 在调用方法中合作等待职分
  • 在异步方法中异步等待任务
  • Task.Delay(卡塔尔(英语:State of Qatar)暂停实践

  

意气风发、相当管理

  await 表明式也得以运用 try…catch…finally 布局。

 1     internal class Program
 2     {
 3         private static void Main(string[] args)
 4         {
 5             var t = DoExceptionAsync();
 6             t.Wait();
 7 
 8             Console.WriteLine($"{nameof(t.Status)}: {t.Status}");   //任务状态
 9             Console.WriteLine($"{nameof(t.IsCompleted)}: {t.IsCompleted}");     //任务完成状态标识
10             Console.WriteLine($"{nameof(t.IsFaulted)}: {t.IsFaulted}");     //任务是否有未处理的异常标识
11 
12             Console.Read();
13         }
14 
15         /// <summary>
16         /// 异常操作
17         /// </summary>
18         /// <returns></returns>
19         private static async Task DoExceptionAsync()
20         {
21             try
22             {
23                 await Task.Run(() => { throw new Exception(); });
24             }
25             catch (Exception)
26             {
27                 Console.WriteLine($"{nameof(DoExceptionAsync)} 出现异常!");
28             }
29         }
30     }

图片 1

图1-1

  【剖析】await
表明式坐落于 try
块中,按平常的艺术管理特别。可是,为啥图中的状态(Status)、是或不是产生标志(IsCompleted)和是不是失利标志(IsFaulted)分别展现:运转成功(RanToCompletion)
、已产生(True) 和 未战败(False)
呢?因为:职分未有被废除,何况极其都已经管理完了!

 

二、在调用方法中同步等待职分

  调用方法可能在有些时刻点上急需等待有些特殊的 Task
对象实现,才实施前面的代码。那个时候,能够选拔实例方法 Wait 。

 1     internal class Program
 2     {
 3         private static void Main(string[] args)
 4         {
 5             var t = CountCharactersAsync("http://www.cnblogs.com/liqingwen/");
 6 
 7             t.Wait();   //等待任务结束
 8             Console.WriteLine($"Result is {t.Result}");
 9 
10             Console.Read();
11         }
12 
13         /// <summary>
14         /// 统计字符数量
15         /// </summary>
16         /// <param name="address"></param>
17         /// <returns></returns>
18         private static async Task<int> CountCharactersAsync(string address)
19         {
20             var result = await Task.Run(() => new WebClient().DownloadStringTaskAsync(address));
21             return result.Length;
22         }
23     }

图片 2

图2-1

 

  Wait(卡塔尔(قطر‎ 符合用来单豆蔻年华 Task 对象,要是想操作生机勃勃组对象,可采用 Task
的八个静态方法 WaitAll(卡塔尔(英语:State of Qatar) 和 WaitAny(卡塔尔(قطر‎ 。

 1     internal class Program
 2     {
 3         private static int time = 0;
 4         private static void Main(string[] args)
 5         {
 6             var t1 = GetRandomAsync(1);
 7             var t2 = GetRandomAsync(2);
 8 
 9             //IsCompleted 任务完成标识
10             Console.WriteLine($"t1.{nameof(t1.IsCompleted)}: {t1.IsCompleted}");    
11             Console.WriteLine($"t2.{nameof(t2.IsCompleted)}: {t2.IsCompleted}");
12 
13             Console.Read();
14         }
15 
16         /// <summary>
17         /// 获取一个随机数
18         /// </summary>
19         /// <param name="id"></param>
20         /// <returns></returns>
21         private static async Task<int> GetRandomAsync(int id)
22         {
23             var num = await Task.Run(() =>
24             {
25                 time++;
26                 Thread.Sleep(time * 100);
27                 return new Random().Next();
28             });
29 
30             Console.WriteLine($"{id} 已经调用完成");
31             return num;
32         }
33     }

图片 3

图2-2 五个职责的 IsCompleted 属性都显得未变成

 

  今后,在 Main() 方法中新扩大两行代码(6 和 7 两行),尝试调用
WaitAll(卡塔尔(英语:State of Qatar) 方法。

 1         private static void Main(string[] args)
 2         {
 3             var t1 = GetRandomAsync(1);
 4             var t2 = GetRandomAsync(2);
 5 
 6             Task<int>[] tasks = new Task<int>[] { t1, t2 };
 7             Task.WaitAll(tasks);    //等待任务全部完成,才继续执行
 8 
 9             //IsCompleted 任务完成标识
10             Console.WriteLine($"t1.{nameof(t1.IsCompleted)}: {t1.IsCompleted}");    
11             Console.WriteLine($"t2.{nameof(t2.IsCompleted)}: {t2.IsCompleted}");
12 
13             Console.Read();
14         }

图片 4

图2-3 多少个职务的 IsCompleted 属性都来得 True

 

  今后,再一次将第 7 行改变一下,调用 WaitAny(卡塔尔国 方法尝试。 

 1         private static void Main(string[] args)
 2         {
 3             var t1 = GetRandomAsync(1);
 4             var t2 = GetRandomAsync(2);
 5 
 6             Task<int>[] tasks = new Task<int>[] { t1, t2 };
 7             Task.WaitAny(tasks);    //等待任一 Task 完成,才继续执行
 8 
 9             //IsCompleted 任务完成标识
10             Console.WriteLine($"t1.{nameof(t1.IsCompleted)}: {t1.IsCompleted}");    
11             Console.WriteLine($"t2.{nameof(t2.IsCompleted)}: {t2.IsCompleted}");
12 
13             Console.Read();
14         }

图片 5

图2-4 有一个义务的 IsCompleted 属性显示 True (完毕) 就继续实施

 

三、在异步方法中异步等待职责

  上节说的是何许运用 WaitAll(卡塔尔(قطر‎ 和 WaitAny(卡塔尔(قطر‎ 同步地伺机 Task
达成。此番大家选用 Task.WhenAll(卡塔尔(قطر‎ 和 Task.WhenAny() 在异步方法中异步等待职分。

 1     internal class Program
 2     {
 3         private static int time = 0;
 4 
 5         private static void Main(string[] args)
 6         {
 7             var t = GetRandomAsync();
 8 
 9             Console.WriteLine($"t.{nameof(t.IsCompleted)}: {t.IsCompleted}");
10             Console.WriteLine($"Result: {t.Result}");
11 
12             Console.Read();
13         }
14 
15         /// <summary>
16         /// 获取一个随机数
17         /// </summary>
18         /// <param name="id"></param>
19         /// <returns></returns>
20         private static async Task<int> GetRandomAsync()
21         {
22             time++;
23             var t1 = Task.Run(() =>
24             {
25                 Thread.Sleep(time * 100);
26                 return new Random().Next();
27             });
28 
29             time++;
30             var t2 = Task.Run(() =>
31             {
32                 Thread.Sleep(time * 100);
33                 return new Random().Next();
34             });
35 
36             //异步等待集合内的 Task 都完成,才进行下一步操作
37             await Task.WhenAll(new List<Task<int>>() { t1, t2 });
38 
39             Console.WriteLine($"    t1.{nameof(t1.IsCompleted)}: {t1.IsCompleted}");
40             Console.WriteLine($"    t2.{nameof(t2.IsCompleted)}: {t2.IsCompleted}");
41 
42             return t1.Result + t2.Result;
43         }
44     }

图片 6

图3-1 调用 WhenAll()  方法

  【注意】WhenAll(卡塔尔国 异步等待集结内的
Task 都成功,不会据有主线程的时日。

 

   现在,大家把 GetRandomAsync(卡塔尔(قطر‎ 方法内的 WhenAll(卡塔尔 方法替换成WhenAny(卡塔尔,并且增大学一年级下线程挂起时间,末了改动如下:

 1         private static async Task<int> GetRandomAsync()
 2         {
 3             time++;
 4             var t1 = Task.Run(() =>
 5             {
 6                 Thread.Sleep(time * 100);
 7                 return new Random().Next();
 8             });
 9 
10             time++;
11             var t2 = Task.Run(() =>
12             {
13                 Thread.Sleep(time * 500);   //这里由 100 改为 500,不然看不到效果
14                 return new Random().Next();
15             });
16 
17             //异步等待集合内的 Task 都完成,才进行下一步操作
18             //await Task.WhenAll(new List<Task<int>>() { t1, t2 });
19             await Task.WhenAny(new List<Task<int>>() { t1, t2 });
20 
21             Console.WriteLine($"    t1.{nameof(t1.IsCompleted)}: {t1.IsCompleted}");
22             Console.WriteLine($"    t2.{nameof(t2.IsCompleted)}: {t2.IsCompleted}");
23 
24             return t1.Result + t2.Result;
25         }

图片 7

图3-2 调用 WhenAny() 方法

 

四、Task.Delay(卡塔尔国 暂停奉行

  Task.Delay(卡塔尔(英语:State of Qatar) 方法会创立一个 Task
对象,该目的将中断其在线程中的管理,并在必然时间之后产生。和
Thread.Sleep 分裂的是,它不会卡住线程,意味着线程能够一连处理任何工作。

 1     internal class Program
 2     {
 3         private static void Main(string[] args)
 4         {
 5             Console.WriteLine($"{nameof(Main)} - start.");
 6             DoAsync();
 7             Console.WriteLine($"{nameof(Main)} - end.");
 8 
 9             Console.Read();
10         }
11 
12         private static async void DoAsync()
13         {
14             Console.WriteLine($"    {nameof(DoAsync)} - start.");
15 
16             await Task.Delay(500);
17 
18             Console.WriteLine($"    {nameof(DoAsync)} - end.");
19         }
20     }

图片 8

图4-1

 

传送门

  入门:《带头接触 async/await
异步编制程序》

  上篇:《走进异步编制程序的社会风气 –
深入分析异步方法(上)》

  下篇:《走进异步编制程序的世界 – 在 GUI
中执行异步操作》

 


 【原作链接】

【参考】《Illustrated C# 2012》

相关文章

发表评论

电子邮件地址不会被公开。 必填项已用*标注

*
*
Website