前言

Talk is cheap, Show you the code first!

private void button1_Click(object sender, EventArgs e)
{Console.WriteLine("111 balabala. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);AsyncMethod();Console.WriteLine("222 balabala. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);
}private async Task AsyncMethod()
{var ResultFromTimeConsumingMethod = TimeConsumingMethod();string Result = await ResultFromTimeConsumingMethod + " + AsyncMethod. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId;Console.WriteLine(Result);//返回值是Task的函数可以不用return
}//这个函数就是一个耗时函数,可能是IO操作,也可能是cpu密集型工作。
private Task<string> TimeConsumingMethod()
{            var task = Task.Run(()=> {Console.WriteLine("Helo I am TimeConsumingMethod. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);Thread.Sleep(5000);Console.WriteLine("Helo I am TimeConsumingMethod after Sleep(5000). My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);return "Hello I am TimeConsumingMethod";});return task;
}

我靠,这么复杂!!!竟然有三个函数!!!竟然有那么多行!!!

别着急,慢慢看完,最后的时候你会发现使用async/await真的炒鸡优雅。

异步方法的结构

上面是一个的使用async/await的例子(为了方便解说原理我才写的这样复杂的)。
使用async/await能非常简单的创建异步方法,防止耗时操作阻塞当前线程。
使用async/await来构建的异步方法,逻辑上主要有下面三个结构:

调用异步方法

private void button1_Click(object sender, EventArgs e)
{Console.WriteLine("111 balabala. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);AsyncMethod();//这个方法就是异步方法,异步方法的调用与一般方法完全一样Console.WriteLine("222 balabala. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);
}

注意:微软建议异步方法的命名是在方法名后添加Aysnc后缀,示例是我为了读起来方便做成了前缀,在真正构建异步方法的时候请注意用后缀。(好吧我承认是我忘记了,然后图片也都截好了再修改太麻烦了。。。。就懒得重新再修改了)

异步方法的返回类型只能是voidTaskTask<TResult>。示例中异步方法的返回值类型是Task

另外,上面的AsyncMethod()会被编译器提示报警,如下图:

因为是异步方法,所以编译器提示在前面使用await关键字,这个后面再说,为了不引入太多概念导致难以理解暂时就先这么放着。

异步方法本体

private async Task AsyncMethod()
{var ResultFromTimeConsumingMethod = TimeConsumingMethod();string Result = await ResultFromTimeConsumingMethod + " + AsyncMethod. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId;Console.WriteLine(Result);//返回值是Task的函数可以不用return
}

async来修饰一个方法,表明这个方法是异步的,声明的方法的返回类型必须为:voidTaskTask<TResult>。方法内部必须含有await修饰的方法,如果方法内部没有await关键字修饰的表达式,哪怕函数被async修饰也只能算作同步方法,执行的时候也是同步执行的。

被await修饰的只能是Task或者Task<TResule>类型,通常情况下是一个返回类型是Task/Task<TResult>的方法,当然也可以修饰一个Task/Task<TResult>变量,await只能出现在已经用async关键字修饰的异步方法中。上面代码中就是修饰了一个变量ResultFromTimeConsumingMethod

关于被修饰的对象,也就是返回值类型是TaskTask<TResult>函数或者Task/Task<TResult>类型的变量:如果是被修饰对象的前面用await修饰,那么返回值实际上是void或者TResult(示例中ResultFromTimeConsumingMethodTimeConsumingMethod()函数的返回值,也就是Task<string>类型,当ResultFromTimeConsumingMethod在前面加了await关键字后 await ResultFromTimeConsumingMethod实际上完全等于 ResultFromTimeConsumingMethod.Result)。如果没有await,返回值就是Task或者Task<TResult>

耗时函数

//这个函数就是一个耗时函数,可能是IO密集型操作,也可能是cpu密集型工作。
private Task<string> TimeConsumingMethod()
{            var task = Task.Run(()=> {Console.WriteLine("Helo I am TimeConsumingMethod. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);Thread.Sleep(5000);Console.WriteLine("Helo I am TimeConsumingMethod after Sleep(5000). My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);return "Hello I am TimeConsumingMethod";});return task;
}

这个函数才是真正干活的(为了让逻辑层级更分明,我把这部分专门做成了一个函数,在后面我会精简一下直接放到异步函数中,毕竟活在哪都是干)。

在示例中是一个CPU密集型的工作,我另开一线程让他拼命干活干5s。如果是IO密集型工作比如文件读写等可以直接调用.Net提供的类库,对于这些类库底层具体怎么实现的?是用了多线程还是DMA?或者是多线程+DMA?这些问题我没有深究但是从表象看起来和我用Task另开一个线程去做耗时工作是一样的。

await只能修饰Task/Task<TResult>类型,所以这个耗时函数的返回类型只能是Task/Task<TResult>类型。

总结:有了上面三个结构就能完成使用一次异步函数。

async/await异步函数的原理

在开始讲解这两个关键字之前,为了方便,对某些方法做了一些拆解,拆解后的代码块用代号指定:

上图对示例代码做了一些指定具体就是:

  • Caller代表调用方函数,在上面的代码中就是button1_Click函数。
  • CalleeAsync代表被调用函数,因为代码中被调用函数是一个异步函数,按照微软建议的命名添加了Async后缀,在上面示例代码中就是AsyncMethod()函数。
  • CallerChild1代表调用方函数button1_Click在调用异步方法CalleeAsync之前的那部分代码。
  • CallerChild2代表调用方函数button1_Click在调用异步方法CalleeAsync之后的那部分代码。
  • CalleeChild1代表被调用方函数AsyncMethod遇到await关键字之前的那部分代码。
  • CalleeChild2代表被调用方函数AsyncMethod遇到await关键字之后的那部分代码。
  • TimeConsumingMethod是指被await修饰的那部分耗时代码(实际上我代码中也是用的这个名字来命名的函数)

示例代码的执行流程


为了方便观看我模糊掉了对本示例没有用的输出。
这里涉及到了两个线程,线程ID分别是1和3。

Caller函数被调用,先执行CallerChild1代码,这里是同步执行与一般函数一样,然后遇到了异步函数CalleeAsync。

在CalleeAsync函数中有await关键字,await的作用是打分裂点。

编译器会把整个函数(CalleeAsync)从这里分裂成两个函数。await关键字之前的代码作为一个函数(按照我上面定义的指代,下文中就叫这部分代码CalleeChild1)await关键字之后的代码作为一个函数(CalleeChild2)。

CalleeChild1在调用方线程执行(在示例中就是主线程Thread1),执行到await关键字之后,另开一个线程耗时工作在Thread3中执行,然后立即返回。这时调用方会继续执行下面的代码CallerChild2(注意是Caller不是Callee)。

在CallerChild2被执行期间,TimeConsumingMethod也在异步执行(可能是在别的线程也可能是CPU不参与操作直接DMA的IO操作)。

当TimeConsumingMethod执行结束后,CalleeChild2也就具备了执行条件,而这个时候CallerChild2可能执行完了也可能没有,由于CallerChild2与CalleeChild2都会在Caller的线程执行,这里就会有冲突应该先执行谁,编译器会在合适的时候在Caller的线程执行这部分代码。示意图如下:

请注意,CalleeChild2在上图中并没有画任何箭头,因为这部分代码的执行是由编译器决定的,暂时无法具体描述是什么时候执行。

总结一下:

整个流程下来,除了TimeConsumingMethod函数是在Thread3中执行的,剩余代码都是在主线程Thread1中执行的.

也就是说异步方法运行在当前同步上下文中,只有激活的时候才占用当前线程的时间,异步模型采用时间片轮转来实现(这一点我没考证,仅作参考)。

你也许会说,明明新加了一个Thread3线程怎么能说是运行在当前的线程中呢?这里说的异步方法运行在当前线程上的意思是由CalleeAsync分裂出来的CalleeChild1和CalleeChild2的确是运行在Thread1上的。

带返回值的异步函数

之前的示例代码中异步函数是没有返回值的,作为理解原理足够了,但是在实际应用场景中,带返回值的应用才是最常用的。那么,上代码:

private void button1_Click(object sender, EventArgs e)
{Console.WriteLine("111 balabala. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);var ResultTask  = AsyncMethod();Console.WriteLine(ResultTask.Result);Console.WriteLine("222 balabala. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);
}private async Task<string> AsyncMethod()
{var ResultFromTimeConsumingMethod = TimeConsumingMethod();string Result = await ResultFromTimeConsumingMethod + " + AsyncMethod. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId;Console.WriteLine(Result);return Result;
}//这个函数就是一个耗时函数,可能是IO操作,也可能是cpu密集型工作。
private Task<string> TimeConsumingMethod()
{            var task = Task.Run(()=> {Console.WriteLine("Helo I am TimeConsumingMethod. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);Thread.Sleep(5000);Console.WriteLine("Helo I am TimeConsumingMethod after Sleep(5000). My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);return "Hello I am TimeConsumingMethod";});return task;
}

主要更改的地方在这里:


按理说没错吧?然而,这代码一旦执行就会卡死。

死锁

是的,死锁。分析一下为什么:

按照之前我划定的代码块指定,在添加了新代码后CallerChild2与CalleeChild2的划分如上图。

这两部分代码块都是在同一个线程上执行的,也就是主线程Thread1,而且通常情况下CallerChild2是会早于CalleeChild2执行的(毕竟CalleeChild2得在耗时代码块执行之后执行)。

Console.WriteLine(ResultTask.Result);(CallerChild2)其实是在请求CalleeChild2的执行结果,此时明显CalleeChild2还没有结束没有return任何结果,那Console.WriteLine(ResultTask.Result);就只能阻塞Thread1等待,直到CalleeChild2有结果。

然而问题就在这,CalleeChild2也是在Thread1上执行的,此时CallerChild2一直占用Thread1等待CalleeChild2的结果,耗时程序结束后轮到CalleeChild2执行的时候CalleeChild2又因Thread1被CallerChild2占用而抢不到线程,永远无法return,那么CallerChild2就会永远等下去,这就造成了死锁。

解决办法有两种一个是把Console.WriteLine(ResultTask.Result);放到一个新开线程中等待(个人觉得这方法有点麻烦,毕竟要新开线程),还有一个方法是把Caller也做成异步方法:

ResultTask.Result变成了ResultTask 的原因上面也说了,await修饰的Task/Task<TResult>得到的是TResult。

之所以这样就能解决问题是因为嵌套了两个异步方法,现在的Caller也成了一个异步方法,当Caller执行到await后直接返回了(await拆分方法成两部分),CalleeChild2执行之后才轮到Caller中await后面的代码块(Console.WriteLine(ResultTask.Result);)。

另外,把Caller做成异步的方法也解决了一开始的那个警告,还记得么?

这样没省多少事啊?

到现在,你可能会说:使用async/await不比直接用Task.Run()来的简单啊?比如我用TaskTaskContinueWith方法也能实现:

private void button1_Click(object sender, EventArgs e)
{var ResultTask = Task.Run(()=> {Console.WriteLine("Helo I am TimeConsumingMethod. My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);Thread.Sleep(5000);Console.WriteLine("Helo I am TimeConsumingMethod after Sleep(5000). My Thread ID is :" + Thread.CurrentThread.ManagedThreadId);return "Hello I am TimeConsumingMethod";});ResultTask.ContinueWith(OnDoSomthingIsComplete);}private void OnDoSomthingIsComplete(Task<string> t)
{Action action = () => {textBox1.Text = t.Result;};textBox1.Invoke(action);Console.WriteLine("Continue Thread ID :" + Thread.CurrentThread.ManagedThreadId);
}

是的,上面的代码也能实现。但是,async/await的优雅的打开方式是这样的:

private async void button1_Click(object sender, EventArgs e)
{var t = Task.Run(() => {Thread.Sleep(5000);return "Hello I am TimeConsumingMethod";});textBox1.Text = await t;
}

看到没,惊不惊喜,意不意外,寥寥几行就搞定了,不用再多写那么多函数,使用起来也很灵活。最让人头疼的跨线程修改控件的问题完美解决了,再也不用使用Invoke了,因为修改控件的操作压根就是在原来的线程上做的,还能不阻塞UI。

参考:
死锁问题 https://www.cnblogs.com/OpenCoder/p/4434574.html
该博主是翻译的英文资料,英文原文:http://blog.stephencleary.com/2012/07/dont-block-on-async-code.html
https://www.cnblogs.com/zhili/archive/2013/05/15/Csharp5asyncandawait.html
http://www.cnblogs.com/heyuquan/archive/2013/04/26/3045827.html
https://docs.microsoft.com/zh-cn/dotnet/csharp/programming-guide/concepts/async/index

引用如果我直接在Main方法里调用异步,你要把Main改成异步?不可能的

可以用同步方式调用异步方法,比如:
AsyncMethod().Wait();
var result = AsyncMethod().Result;

111 balabala. My Thread ID is :1
Helo I am TimeConsumingMethod. My Thread ID is :3
Helo I am TimeConsumingMethod after Sleep(5000). My Thread ID is :3
Hello I am TimeConsumingMethod + AsyncMethod. My Thread ID is :3
Hello I am TimeConsumingMethod + AsyncMethod. My Thread ID is :3
222 balabala. My Thread ID is :1

我的输出结果

所以并不是这么容易就出现死锁,而是变成了同步执行,等待执行结果了吧

C# 彻底搞懂async/await相关推荐

  1. 【转】C# 彻底搞懂async/await

    关键: 异步方法:在执行完成前立即返回调用方法,在调用方法继续执行的过程中完成任务. async/await 结构可分成三部分: (1)调用方法:该方法调用异步方法,然后在异步方法执行其任务的时候继续 ...

  2. 一次性搞懂JavaScript 执行机制

    你是否遭受到这样的恐吓? 你是否有过每个表达式前面都console一遍值去找执行顺序? 看了很多js执行机制的文章似乎都是似懂非懂,到技术面问的时候,理不清思绪.总结了众多文章的例子和精华,希望能帮到 ...

  3. 异步编程:一次搞懂Promise,async,await

    文章目录 前言 一.回调函数 二.Promise 三.错误处理 四.async/await await使用时的陷阱 1 2 3 总结 前言 异步编程允许我们在执行一个长时间任务时,程序不需要进行等待, ...

  4. 一文看懂async和“await”关键词是如何简化了C#中多线程的开发过程

    一文看懂"async"和"await"关键词是如何简化了C#中多线程的开发过程 当我们使用需要长时间运行的方法(即,用于读取大文件或从网络下载大量资源)时,在同 ...

  5. 一眼看懂promise与async await的区别

    // promise方法let p1 = new Promise((resolve,reject) => {setTimeout(() => {resolve('我是p1')},4000) ...

  6. 在.NET中执行Async/Await的两种错误方法

    微信公众号:架构师高级俱乐部 关注可了解更多的编程,架构知识.问题或建议,请公众号留言; 如果你觉得此文对你有帮助,欢迎转发 在.NET中执行异步/等待的两种错误方法 在应用开发中,我们为了提高应用程 ...

  7. 转:前端 100 问:能搞懂80%的请把简历给我

    <前端 100 问:能搞懂80%的请把简历给我> 引言 半年时间,几千人参与,精选大厂前端面试高频 100 题,这就是「壹题」. 在 2019 年 1 月 21 日这天,「壹题」项目正式开 ...

  8. 这次彻底搞懂 Promise(手写源码多注释篇)

    作者:一阵风,一枚只想安静写代码的程序员,来自程序员成长指北交流群    github: https://github.com/yizhengfeng-jj/promise 前言 promise 是 ...

  9. 【JS】1015- 异步编程的终极解决方案 async/await

    早期的回调函数 回调函数我们经常有写到,比如: ajax(url, (res) => {console.log(res); }) 复制代码 但是这种回调函数有一个大缺陷,就是会写出 回调地狱(C ...

最新文章

  1. FPGA 控制 FLASH 之 Startup 原语使用相关链接
  2. Objective-C中把URL请求的参数转换为字典
  3. 145.单工、半单工、双工
  4. 国家开放大学计算机应用模块3客观题答案,国家开放大学《计算机应用基础》考试与答案形考任务模块3模块3Excel2010电子表格系统—客观题答案.pdf...
  5. 飞鸽传书2007的java学习感想
  6. SQL Server 2017:mTVF的交错执行
  7. python查看微信撤回消息_python实现文件助手中查看微信撤回消息
  8. matlab mysql数据库增删改查_ef6.0增删改查操作
  9. oracle匹配excel数据,ORACLE与excel的数据互传方法
  10. 蓝色学校网站模板_中小学网站源码_学校网站管理系统
  11. BZOJ 4698 Sdoi2008 Sandy的卡片
  12. 自学编程的30岁男人,能按应届生那样找工作吗?
  13. 红烧茄子做法--小黄讲解
  14. fastjson 属性大写问题
  15. 图:两点之间的最短距离
  16. odoo----权限机制
  17. Zhong__Go随机密码生成器
  18. Codeforces-1008A - Romaji - 水题
  19. 用于 CKeditor 编辑器的可视化数学公式插件
  20. CPU的工作电压(核心电压,I/O电压)

热门文章

  1. [BZOJ 3647]
  2. java集合类分析-hashset
  3. 好文推荐系列--------(3)GruntJS 在线重载 提升生产率至新境界
  4. 面试题12:打印1到最大的n位数
  5. Libevent:6辅助函数以及类型
  6. 【转发】响应式Web设计?怎样进行?
  7. OpenGL ES 2.0 for iPhone Tutorial
  8. ckedit 3.0 配置(一)
  9. 第九章 隐马尔科夫模型HMM
  10. git 怎么拉去分支代码_Git使用技巧1——代码写错分支了怎么办?