多线程编程学习笔记——async和await(二)
2018-06-18 00:33:54来源:未知 阅读 ()
接上文 多线程编程学习笔记——async和await(一)
三、 对连续的异步任务使用await操作符
本示例学习如何阅读有多个await方法方法时,程序的实际流程是怎么样的,理解await的异步调用 。
1。示例代码如下。
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Threading; namespace ThreadAsyncDemo { class Program { static void Main(string[] args) {
Console.WriteLine(string.Format("----- 对连续的异步任务使用await操作符----"));
Task t = AsyncWithTPL(); t.Wait(); t = AsyncWithAwait(); t.Wait(); Console.Read(); } static Task AsyncWithTPL() { var containerTask = new Task(() => { Task<string> task1 = GetInfoAsync("TPL Task 1"); task1.ContinueWith(task => { Console.WriteLine(task1.Result); Task<string> task2 = GetInfoAsync("TPL Task 2"); task2.ContinueWith(innerTask => Console.WriteLine(innerTask.Result), TaskContinuationOptions.NotOnFaulted | TaskContinuationOptions.AttachedToParent); task2.ContinueWith(innerTask => Console.WriteLine(innerTask.Exception.InnerException), TaskContinuationOptions.OnlyOnFaulted | TaskContinuationOptions.AttachedToParent); }, TaskContinuationOptions.NotOnFaulted | TaskContinuationOptions.AttachedToParent); task1.ContinueWith(task => Console.WriteLine(task1.Exception.InnerException), TaskContinuationOptions.OnlyOnFaulted | TaskContinuationOptions.AttachedToParent); } ); containerTask.Start(); return containerTask; } async static Task AsyncWithAwait() { try { string result = await GetInfoAsync("Async Task 1"); Console.WriteLine(result); result = await GetInfoAsync("Async Task 2"); Console.WriteLine(result); } catch (Exception ex) { Console.WriteLine(ex.Message); } } async static Task<string> GetInfoAsync(string name) { Console.WriteLine(string.Format("任务 {0} 开始。。。",name)); await Task.Delay(TimeSpan.FromSeconds(2)); if(name== "TPL Task 2") throw new Exception(string.Format("{0} 抛出异常信息!", name)); return string.Format(" Task {0} 正在运行在线程 ID={1}上。这个工作线程是否是线程池中的线程:{2}", name,
Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread); } } }
2.程序运行结果,如下图。
首先,程序运行时会执行两个异步操作。
- AsyncWithAwait方法,它看起来跟平常的代码一样,唯一不同之处就是使用了两个await声明。最重要的一点是代码的执行顺序依然是顺序执行的,调用AsyncWithAwait任务的代码只有等 之前的的任务完成 后才会开始执行。当阅读代码时,程序流很清晰,可以看到什么先执行,什么后执行,但是程序如何异步执行呢?首先,它不是一直是异步执行的,只有当使用await,且一个任务已经完成,我们会异步地得 到这个任务的结果。否则 ,当在代码中看到await声明时,通过的行为是代码执行到await代码行时将立即返回,并且剩下的代码将会在一个后续操作任务中运行。因此等待操作结果时并没有阻塞程序执行,这是一个异步调用 。当AsyncWithAwait方法中的代码执行时,除了在main方法中调用 t.wait外,我们可以执行任务其他任务。但是主线程必须等待直到所有的异步操作完成 ,否则 主线程完成后所有运行异步操作的后台线程会停止运行。
- AsyncWithTPL方法模仿了AsyncWithAwait的程序流。我们需要一个容器任务来处理所有相互依赖的任务。然后启动主任务,给其加了一组后续操作。当这个任务完成 后,会打印其结果。然后又启动了一个任务,在这个任务完成后会依次运行更多的后续操作。为了测试对异常的处理,当运行第二个任务时故意抛出了一个异常。并打印出异常信息。这组后续操作创建了与第一个方法中一样的程序流。
二、 对并行执行的异步任务使用await操作符
本示例学习如何使用await来并行地运行异步任务,而不采用常规使用顺序执行方式。
1.示例代码如下。
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Threading; namespace ThreadAsyncDemo { class Program { static void Main(string[] args) { Console.WriteLine(string.Format("----- 对并行执行的异步任务使用await操作符----")); Task t = AsyncProcess(); t.Wait(); Console.Read(); } async static Task AsyncProcess() { Task<string> task1 = GetInfoAsync("Task 1",3); Task<string> task2 = GetInfoAsync("Task 2",5); string[] results = await Task.WhenAll(task1, task2); foreach (var item in results) { Console.WriteLine(item); } } async static Task<string> GetInfoAsync(string name,int second) { Console.WriteLine(string.Format("任务 {0} 开始。。。",name)); await Task.Delay(TimeSpan.FromSeconds(second)); //await Task.Run(() => Thread.Sleep(TimeSpan.FromSeconds(second)); return string.Format(" Task {0} 正在运行在线程 ID={1}上。这个工作线程是否是线程池中的线程:{2}", name,
Thread.CurrentThread.ManagedThreadId, Thread.CurrentThread.IsThreadPoolThread); } } }
2.程序运行结果,如下图。
在AsyncProcess方法中定义了两个异步任务task1,task2,分别运行3秒和5秒。然后使用Task.WhenAll辅助方式得到了两个任务的运行结果,而且只有在所有底层任务完成之后,才会运行。之后我们等待这个组合任务的结果。5秒后,我们获取所有结果,说明了这些任务是同时运行的。
我们仔细观察会发现,这两个任务假托是被线程池中的同一个工作线程执行的。当我们并行运行任务时怎么可能发生这样的情况呢?我们注释掉GetIntroAsync方法中的await Task.Delay代码 行,并解除对await task.run代码行的注释,然后再次运行程序。
我们会看到这种情况下,两个任务会被不同的工作线程执行。不同之处是task.delay在幕后使用了一个计时器,过程如下:从线程池中获取工作线程,它将等待task.delay方法返回结果。然后task.delay方法启动计时器并指定一段代码,这段代码会在计时器时间到了task.delay方法中指定的秒数后被 调用 ,之后,立即将工作线程返回到线程池中。当计时器事件运行时,又从线程池中任意获取一个可用的工作线程(可能跟上次运行的是同一个工作线程),并运行计时器指定的代码。
当使用task.run方法时,从线程池中获取了一个工作线程并将其阻塞几秒,然后获取了第二个工作线程也将其阻塞。在这种情况下,我们消费了两个工作线程,但是什么事情也没做。如下图。比较两者的不同之处,在于两个task运行在不同的线程上。
标签:
版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有
下一篇:8.C#知识点:委托和事件
- 如何0基础学习C/C++? 2020-06-06
- vtk学习记录(三)——初识vtkRenderer 2020-05-16
- C代做 C++代做 C++编程代做 C++程序代做 2020-04-29
- C++基础 学习笔记六:复合类型之数组 2020-04-25
- C++基础 学习笔记五:重载之运算符重载 2020-04-23
IDC资讯: 主机资讯 注册资讯 托管资讯 vps资讯 网站建设
网站运营: 建站经验 策划盈利 搜索优化 网站推广 免费资源
网络编程: Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它
服务器技术: Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护
软件技巧: 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷
网页制作: FrontPages Dreamweaver Javascript css photoshop fireworks Flash