-
.NET异步和多线程系列(六)- async/await
本文是.NET异步和多线程系列的第六章,本章主要对之前介绍过的async/await做一些补充说明。
下面我们直接来看下代码和运行结果:
using System; using System.Threading; using System.Threading.Tasks; namespace MyAsyncAwait { /// <summary> /// await/async 是C#保留关键字,通常是成对出现,语法糖。 /// /// 主线程调用async/await方法,主线程遇到await返回执行后续动作, /// await后面的代码会等着Task任务的完成后再继续执行 /// 其实就像把await后面的代码包装成一个ContinueWith的回调动作 /// 然后这个回调动作可能是Task线程,也可能是新的子线程,也可能是主线程 /// /// 一个async方法,如果没有返回值,可以方法声明返回Task /// await/async能够用同步的方式编写代码,但又是非阻塞的。 /// /// async方法在编译后会生成一个状态机(实现了IAsyncStateMachine接口) /// </summary> class Program { static void Main(string[] args) { Console.WriteLine($"当前主线程开始 ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); AwaitAsyncClass.TestShow(); Console.WriteLine($"当前主线程结束 ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); Console.ReadKey(); } } /// <summary> /// await/async关键字 语法糖 /// await/async 要么不用 要么用到底 /// </summary> public class AwaitAsyncClass { public static void TestShow() { Test(); } private async static Task Test() { Console.WriteLine($"Test开始 ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); Task<long> t = SumAsync(); Console.WriteLine($"遇到await主线程回来干活了 ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); { long lResult = await t; //await后面的代码会由线程池的线程执行,非阻塞。 Console.WriteLine($"最终得到的lResult={lResult}"); } { //t.Wait(); //主线程等待Task的完成,阻塞的 //long lResult = t.Result; //访问Result,主线程等待Task的完成,阻塞的,效果跟t.Wait()一样 //Console.WriteLine($"最终得到的lResult={lResult}"); } Console.WriteLine($"Test结束 ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); } /// <summary> /// 带返回值的Task /// 要使用返回值就一定要等子线程计算完毕 /// </summary> private static async Task<long> SumAsync() { Console.WriteLine($"SumAsync start ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); long result = 0; //await后面的代码会等着Task任务的完成后再继续执行 //其实就像把await后面的代码包装成一个ContinueWith的回调动作 //然后这个回调动作可能是Task线程,也可能是新的子线程,也可能是主线程 await Task.Run(() => { for (int k = 0; k < 2; k++) { Console.WriteLine($"SumAsync 第1个 await Task.Run k={k} ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); Thread.Sleep(1000); } for (long i = 0; i < 999_999_999; i++) { result += i; } }); Console.WriteLine($"SumAsync 第1个 await Task.Run的后续任务开始 ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); await Task.Run(() => { for (int k = 0; k < 2; k++) { Console.WriteLine($"SumAsync 第2个 await Task.Run k={k} ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); Thread.Sleep(1000); } for (long i = 0; i < 999_999_999; i++) { result += i; } }); Console.WriteLine($"SumAsync 第2个 await Task.Run的后续任务开始 ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); await Task.Run(() => { for (int k = 0; k < 2; k++) { Console.WriteLine($"SumAsync 第3个 await Task.Run k={k} ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); Thread.Sleep(1000); } for (long i = 0; i < 999_999_999; i++) { result += i; } }); Console.WriteLine($"SumAsync end ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); return result; } } }
运行结果如下:
仔细观察结果会发现:
主线程调用async/await方法,主线程遇到await后会返回执行后续动作;
await后面的代码会等着Task任务的完成后再继续执行,其实就像把await后面的代码包装成一个ContinueWith的回调动作;
然后这个回调动作可能是Task线程,也可能是新的子线程,也可能是主线程;
await/async能够用同步的方式编写代码,但又是非阻塞的。
下面我们调整下Test方法后再运行(红色的为调整部分):
private async static Task Test() { Console.WriteLine($"Test开始 ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); Task<long> t = SumAsync(); Console.WriteLine($"遇到await主线程回来干活了 ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); { //long lResult = await t; //await后面的代码会由线程池的线程执行,非阻塞。 //Console.WriteLine($"最终得到的lResult={lResult}"); } { //t.Wait(); //主线程等待Task的完成,阻塞的 long lResult = t.Result; //访问Result,主线程等待Task的完成,阻塞的,效果跟t.Wait()一样 Console.WriteLine($"最终得到的lResult={lResult}"); } Console.WriteLine($"Test结束 ManagedThreadId={Thread.CurrentThread.ManagedThreadId}"); }
调整后运行结果如下:
仔细观察结果会发现:
访问Result,主线程会等待Task的完成,阻塞的。
其实async方法在编译后会生成一个状态机(实现了IAsyncStateMachine接口),有兴趣的可以自行去了解下。
至此本文就介绍完了,有兴趣的还可以看下我之前写过一篇也是关于async/await的文章:https://www.cnblogs.com/xyh9039/p/11391507.html
Demo源码:
链接:https://pan.baidu.com/s/1jnG5IpteuKCdmF6-tr--cA 提取码:3onm
此文由博主精心撰写转载请保留此原文链接:https://www.cnblogs.com/xyh9039/p/13622122.html
版权声明:如有雷同纯属巧合,如有侵权请及时联系本人修改,谢谢!!!
最新更新
Python获取微信好友数据
Python 的排序方法 sort 和 sorted 的区别
WinForm轻松实现自定义分页 (转载)
Mac系统下使用brew搭建PHP(LNMP/LAMP)开发环境
在win系统安装配置 Memcached for PHP 5.3 图文
箱图在数据预处理中的应用
Python WEB开发:用Tornado框架制作简易【表
自从学会了用python解析视频,都不用去找
Python代码阅读(第50篇):对列表间隔取
Python爬虫+数据分析+可视化展示,分析《
MongoDB常用命令(2)
MongoDB基本介绍与安装(1)
SQLServer触发器调用JavaWeb接口
SQL Server索引的原理深入解析
SqlServer2016模糊匹配的三种方式及效率问题
SQL中Truncate的用法
sqlserver 多表关联时在where语句中慎用tri
链接服务器读取Mysql---出现消息 7347,级别
SQL Server解惑——为什么你拼接的SQL语句换
MySQL视图了解一下
laf.js - 开源的云开发框架(README.md)
javascript创建对象
Node.js 源码分析 - 从 main 函数开始
Node.js 源码分析 - 原生模块(C++模块)的注册
ECharts图标中用的js相关的处理方法
GoJS 使用笔记
单元测试 - 测试场景记录
Node.js 源码分析 - 加载 js 文件
ES6入门
聊聊动效降级