C# 彻底搞懂async/await

前言

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后缀，示例是我为了读起来方便做成了前缀，在真正构建异步方法的时候请注意用后缀。(好吧我承认是我忘记了，然后图片也都截好了再修改太麻烦了。。。。就懒得重新再修改了)

异步方法的返回类型只能是void、Task、Task<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来修饰一个方法，表明这个方法是异步的，声明的方法的返回类型必须为：void或Task或Task<TResult>。方法内部必须含有await修饰的方法，如果方法内部没有await关键字修饰的表达式，哪怕函数被async修饰也只能算作同步方法，执行的时候也是同步执行的。

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

关于被修饰的对象，也就是返回值类型是Task和Task<TResult>函数或者Task/Task<TResult>类型的变量：如果是被修饰对象的前面用await修饰，那么返回值实际上是void或者TResult（示例中ResultFromTimeConsumingMethod是TimeConsumingMethod()函数的返回值，也就是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()来的简单啊？比如我用Task的TaskContinueWith方法也能实现：

复制代码

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

我的输出结果

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

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/438556.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

matlab平滑窗滤波,matlab实现平滑滤波

matlab平滑窗滤波,matlab实现平滑滤波

clc;clear;close all;imimread(‘p1.jpg‘);im rgb2gray(im);imdouble(im);imim/max(im(??);figure(‘Name‘,‘原图‘,‘NumberTitle‘,‘off‘);imshow(im,[0,1]);P1 imnoise(im,‘gaussian‘,0,0.005); % adding gaussian noise 这里im是原始图像&#xff0c;添加了均值…
阅读更多...
c#之task与thread区别及其使用

c#之task与thread区别及其使用

1.什么是thread 当我们提及多线程的时候会想到thread和threadpool&#xff0c;这都是异步操作&#xff0c;threadpool其实就是thread的集合&#xff0c;具有很多优势&#xff0c;不过在任务多的时候全局队列会存在竞争而消耗资源。thread默认为前台线程&#xff0c;主程序必须等…
阅读更多...
java内存分配和垃圾回收,Java内存分配与垃圾回收

java内存分配和垃圾回收,Java内存分配与垃圾回收

1.JVM管理的内存包含下图所示的几个运行时数据区域&#xff0c;其中方法区和堆为线程共享的数据区域&#xff0c;程序计数器&#xff0c;虚拟机栈以及本地方法栈为线程私有的数据区域。程序计数器&#xff1a;可以看做是当前线程所执行的字节码的行号指示器&#xff0c;告诉字节…
阅读更多...
谈谈你对闭包的理解？

谈谈你对闭包的理解？

闭包这个概念好难理解&#xff0c;身边朋友们好多都稀里糊涂的&#xff0c;稀里糊涂的林老冷希望写下这篇文章能够对稀里糊涂的伙伴们有一些帮助~ 请大家跟我理解一下&#xff0c;如果在一个函数的内部定义了另一个函数&#xff0c;外部的我们叫他外函数&#xff0c;内部的我们…
阅读更多...
php有哪些开源社区,PHP开源社区

php有哪些开源社区,PHP开源社区

简介Blade 是 Laravel 提供的一个简单而又强大的模板引擎。和其他流行的 PHP 模板引擎不同&#xff0c;Blade 并不限制你在视图中使用原生 PHP 代码。所有 Blade 视图文件都将被编译成原生的 PHP 代码并缓存起来&#xff0c;除非它被修改&#xff0c;否则不会重新编译&#xff…
阅读更多...
GetType和typeof的区别

GetType和typeof的区别

typeof: The typeof operator is used to obtain the System.Type object for a type. 运算符&#xff0c;获得某一类型的 System.Type 对象。 Type t typeof(int); GetType: Gets the Type of the current instance. 方法&#xff0c;获取当前实例的类型。 int i 10; Consol…
阅读更多...
PHP mysql数据迁移,如何自动化PHP/MySQL应用程序的迁移(架构和数据)

PHP mysql数据迁移,如何自动化PHP/MySQL应用程序的迁移(架构和数据)

我有一个“Schema”对象&#xff0c;我使用 – 但你可以做同样没有类..你想做的是创建一个“db_schema_versions”表&#xff1a;CREATE TABLE db_schema_versions (table varchar(255) NOT NULL PRIMARY KEY,version INT NOT NULL)在您的数据库可以跟踪它是什么版本#之后 – 它…
阅读更多...
【转】c# 协变与抗变

【转】c# 协变与抗变

转自&#xff1a; 协变和抗变 一.定义 在说定义之前&#xff0c;先看一个简单的例子&#xff1a; public class Shape { } public class Rectange : Shape { } 上面定义了两个简单的类&#xff0c;一个是图形类&#xff0c;一个是矩形类&#xff1…
阅读更多...
逆变与协变

逆变与协变

一、遇到问题 这是基于.net3.5开发&#xff0c;实际工作中遇到一个问题。假设我们有一个 Base 类&#xff0c;一个 Derived 类&#xff0c;Derived 继承了 Base。如下&#xff1a; 1 2 3 4 5 6 7 8 class Base { } class Derived : Base { }　　 当我用IEnumerable<Bas…
阅读更多...
php新手用7.2,总结PHP升级7.2之后需要注意的事情

php新手用7.2,总结PHP升级7.2之后需要注意的事情

最近升级了PHP版本&#xff0c;从7.1升级到7.2&#xff0c;升级前版本&#xff1a;PHP 7.1.14 (cli) (built: Feb 2 2018 08:42:59) ( NTS ) Copyright (c) 1997-2018 The PHP Group Zend Engine v3.1.0, Copyright (c) 1998-2018 Zend Technologies with Zend OPcache v7.1.14…
阅读更多...
第一节: 结合EF的本地缓存属性来介绍【EF增删改操作】的几种形式

第一节: 结合EF的本地缓存属性来介绍【EF增删改操作】的几种形式

一. 背景 说起EF的增删改操作&#xff0c;相信很多人都会说&#xff0c;有两种方式&#xff1a;① 通过方法操作 和 ② 通过状态控制。 相信你在使用EF进行删除或修改操作的时候&#xff0c;可能会遇到以下错误&#xff1a;“ The object cannot be deleted because it was n…
阅读更多...
win7和mysql乱码,win7 mysql中文乱码怎么处理

win7和mysql乱码,win7 mysql中文乱码怎么处理

方法/步骤【第一步】在mysql dos命令窗口中输入下面这段命令SHOW VARIABLES LIKE character_set_%; //注 用于显示【mysql 的编码设置】2显示了之后 显示你的mysql编码设置和我的不同之处改掉就OK了【你直接复制下面的命令 粘贴到dos命令窗口中就OK了】【注 我这个改法 只有新添…
阅读更多...
第十六节：语法总结(3)(C#6.0和C#7.0新语法)

第十六节：语法总结(3)(C#6.0和C#7.0新语法)

一. C# 6.0 新语法 1. 自动属性初始化可以赋值 1 /// <summary>2 /// 自动属性初始化3 /// </summary>4 public class UserInfor5 {6 public string userId { get; set; } "123456";7 8 public string userName {…
阅读更多...
php仿伊人集源码,仿伊人集wecenter（）包含所有功能及官方付费插件，整站带数据...

php仿伊人集源码,仿伊人集wecenter（）包含所有功能及官方付费插件，整站带数据...

演示地址&#xff1a;如有演示站请以演示为准&#xff0c;无演示站以截图为准,源码太多服务器有限&#xff0c;无法搭建所有源码演示站&#xff0c;请谅解&#xff01;新手购买指导&#xff1a;1.在本站注册账号 丨 2.登录已注册账号充值源码所需金币 丨 3.登录账号下载所需源码…
阅读更多...
第十七节：易混淆的概念(静态和非静态、拆箱和装箱)

第十七节：易混淆的概念(静态和非静态、拆箱和装箱)

一. 静态和非静态 1. 概念介绍 ① 静态类&#xff08;被static修饰&#xff09; vs 普通类&#xff08;没有被static修饰&#xff09; ② 静态成员&#xff1a;被static修饰的成员&#xff0c;比如&#xff1a;静态方法、静态字段等 ③ 普通成员(实例成员)&#xff1a;不被st…
阅读更多...
perl连接oracle的方法,Perl 连接Oracle 数据库

perl连接oracle的方法,Perl 连接Oracle 数据库

1.安装DBI和DBD::Oracle 模块。下载地址&#xff1a;搜索DBI&#xff0c;DBD::Oracle如果你的linux可以连接网络&#xff0c;执行命令&#xff1a;#wget#wget下载到当前目录。2.安装这里主要都是源码安装。解压到目录&#xff1a;DBI-1.622#tar –zxvf DBI-1.622.tar.gz安装可…
阅读更多...
第十八节：跨域请求的解决方案和WebApi特有的处理方式

第十八节：跨域请求的解决方案和WebApi特有的处理方式

一. 简介 前言&#xff1a; 跨域问题发生在Javascript发起Ajax调用&#xff0c;其根本原因是因为浏览器对于这种请求&#xff0c;所给予的权限是较低的&#xff0c;通常只允许调用本域中的资源&#xff0c; 除非目标服务器明确地告知它允许跨域调用。假设我们页面或者应用已在 …
阅读更多...
bit类型在oracle,奇怪的Oracle bitand函数

bit类型在oracle,奇怪的Oracle bitand函数

最近在用Oracle的bitand函数是遇到了一个奇怪的现象&#xff1a;declaren number default374123538;val number;begindbms_output.enable;val : bitand(n,16777215);dbms_output.put_line(val);end;/结果正确&#xff1a;5024786PL/SQL procedure successfully completed然后修…
阅读更多...
ORM系列之Entity FrameWork详解

ORM系列之Entity FrameWork详解

一. 谈情怀 从第一次接触开发到现在&#xff08;2018年&#xff09;&#xff0c;大约有六年时间了&#xff0c;最初阶段连接数据库&#xff0c;使用的是【SQL语句ADO.NET】&#xff0c;那时候&#xff0c;什么存储过程、什么事务 统统不理解&#xff0c;生硬的将SQL语句传入SQL…
阅读更多...
oracle行转列 case,Oracle 行转列总结 Case When,Decode,PIVOT 三种方式

oracle行转列 case,Oracle 行转列总结 Case When,Decode,PIVOT 三种方式

Decode 方式 SELECT a.COUNTRY AS "国家", SUM(DECODE(a.SEX, 1, a.POPULCATION)) AS "男", SUM(DECODE(a.SEX, 2, a.POPULCATION)) AS "女" FROM populations a GROUP BY a.COUNTRY -------------------------------------- Case When 方式 SEL…
阅读更多...
最新文章

Copyright @ 2022~2023