C#异步编程由浅入深(二)之Async/Await的使用
作者：白烟染黑墨 发布时间：2022-10-14 16:45:20
  考虑到直接讲实现一个类Task库思维有点跳跃,所以本节主要讲解Async/Await的本质作用（解决了什么问题），以及Async/Await的工作原理。实现一个类Task的库则放在后面讲。首先回顾一下上篇博客的场景。
class Program
{
public static string GetMessage()
{
return Console.ReadLine();
}
public static string TranslateMessage(string msg)
return msg;
public static void DispatherMessage(string msg)
switch (msg)
{
case "MOUSE_MOVE":
{
OnMOUSE_MOVE(msg);
break;
}
case "MOUSE_DOWN":
OnMouse_DOWN(msg);
default:
break;
}
public static void OnMOUSE_MOVE(string msg)
Console.WriteLine("开始绘制鼠标形状");
public static int Http()
Thread.Sleep(1000);//模拟网络IO延时
return 1;
public static void HttpAsync(Action<int> action,Action error)
//这里我们用另一个线程来实现异步IO，由于Http方法内部是通过Sleep来模拟网络IO延时的，这里也只能通过另一个线程来实现异步IO
//但记住，多线程是实现异步IO的一个手段而已，它不是必须的，后面会讲到如何通过一个线程来实现异步IO。
Thread thread = new Thread(() =>
try
{
int res = Http();
action(res);
}
catch
error();
});
thread.Start();
public static Task<int> HttpAsync()
return Task.Run(() =>
return Http();
public static void OnMouse_DOWN(string msg)
HttpAsync()
.ContinueWith(t =>
if(t.Status == TaskStatus.Faulted)
}else if(t.Status == TaskStatus.RanToCompletion)
Console.WriteLine(1);
//做一些工作
})
if (t.Status == TaskStatus.Faulted)
else if (t.Status == TaskStatus.RanToCompletion)
Console.WriteLine(2);
Console.WriteLine(3);
});
static void Main(string[] args)
while (true)
string msg = GetMessage();
if (msg == "quit") return;
string m = TranslateMessage(msg);
DispatherMessage(m);
}
  在OnMouse_DOWN这个处理函数中，我们使用Task的ContinueWith函数进行链式操作，解决了回调地狱问题，但是总感觉有点那么不爽，我们假想有个关键字await它能实现以下作用：首先await必须是Task类型，必须是Task类型的（其实不是必要条件，后面会讲到）原因是保证必须有ContinueWith这个函数，如果Task没有返回值，则把await后面的代码放到Task中的ContinueWith函数体内，如果有返回值，则把Await后的结果转化为访问Task.Result属性，文字说的可能不明白，看下示例代码
//无返回值转换前
public async void Example()
{
Task t = Task.Run(() =>
{
Thread.Sleep(1000);
});
await t;
//做一些工作
}
//无返回值转换后
public void Example()
t.ContinueWith(task =>
//做一些工作
//有返回值转换前
Task<int> t = Task.Run<int>(() =>
return 1;
int res = await t;
//使用res做一些工作
//有返回值转换后
//使用task.Result做一些工作
  看起来不错，但至少有以下问题，如下：
该种转换方法不能很好的转换Try/Catch结构
在循环结构中使用await不好转换
该实现与Task类型紧密联系
  一二点是我自己认为的，但第三点是可以从扩展async/await这点被证明的。但无论怎样，async/await只是对方法按照一定的规则进行了变换而已，它并没有什么特别之处，具体来讲，就是把Await后面要执行的代码放到一个类似ContinueWith的函数中，在C#中，它是以状态机的形式表现的，每个状态都对应一部分代码，状态机有一个MoveNext()方法，MoveNext()根据不同的状态执行不同的代码，然后每个状态部分对应的代码都会设置下一个状态字段，然后把自身的MoveNext()方法放到类似ContinueWith()的函数中去执行，整个状态机由回调函数推动。我们尝试手动转换以下async/await方法。
public static Task WorkAsync()
{
return Task.Run(() =>
{
Thread.Sleep(1000);
Console.WriteLine("Done!");
});
}
public static async void Test()
{
Console.WriteLine("步骤1");
await WorkAsync();
Console.WriteLine("步骤2");
await WorkAsync();
Console.WriteLine("步骤3");
}
  手动写一个简单的状态机类
public class TestAsyncStateMachine
{
public int _state = 0;
public void Start() => MoveNext();
public void MoveNext()
{
switch(_state)
{
case 0:
{
goto Step0;
}
case 1:
goto Step1;
default:
Console.WriteLine("步骤3");
return;
}
Step0:
Console.WriteLine("步骤1");
_state = 1;
WorkAsync().ContinueWith(t => this.MoveNext());
return;
Step1:
_state = -1;
Console.WriteLine("步骤2");
}
}
  而Test()方法则变成了这样
public static void Test()
{
new TestAsyncStateMachine().Start();
}
  注意Test()方法返回的是void，这意味这调用方将不能await Test()。如果返回Task，这个状态机类是不能正确处理的，如果要正确处理，那么状态机在Start()启动后，必须返回一个Task，而这个Task在整个状态机流转完毕后要变成完成状态，以便调用方在该Task上调用的ContinueWith得以继续执行，而就Task这个类而言，它是没有提供这种方法（内部有，但没有对外暴露）来主动控制Task的状态的，这个与JS中的Promise不同，JS里面用Reslove函数来主动控制Promise的状态，并导致在该Promise上面的Then链式调用得以继续完成，而在C#里面怎么做呢？既然使用了状态机来实现async/await，那么在转换一个返回Task的函数时肯定会遇到，怎么处理？后面讲。
  首先解决一下与Task类型紧密联系这个问题。
  从状态机中可以看到，主要使用到了Task中的ContinueWith这个函数，它的语义是在任务完成后，执行回调函数，通过回调函数拿到结果，这个编程风格也叫做CPS（Continuation-Passing-Style, 续体传递风格），那么我们能不能把这个函数给抽象出来呢？语言开发者当然想到了，它被抽象成了一个Awaiter因此编译器要求await的类型必须要有GetAwaiter方法，什么样的类型才是Awaiter呢？编译器规定主要实现了如下几个方法的类型就是Awaiter:
必须继承INotifyCompletion接口，并实现其中的OnCompleted(Action continuation)方法
必须包含IsCompleted属性
必须包含GetResult()方法
  第一点好理解，第二点的作用是热路径优化，第三点以后讲。我们再改造一下我们手动写的状态机。
public class TestAsyncStateMachine
{
public int _state = 0;
public void Start() => MoveNext();
public void MoveNext()
{
switch(_state)
{
case 0:
{
goto Step0;
}
case 1:
goto Step1;
default:
Console.WriteLine("步骤3");
return;
}
Step0:
Console.WriteLine("步骤1");
_state = 1;
TaskAwaiter taskAwaiter;
taskAwaiter = WorkAsync().GetAwaiter();
if (taskAwaiter.IsCompleted) goto Step1;
taskAwaiter.OnCompleted(() => this.MoveNext());
return;
Step1:
_state = -1;
Console.WriteLine("步骤2");
if (taskAwaiter.IsCompleted) MoveNext();
}
}
  可以看到去掉了与Task中ContinueWith的耦合关系，并且如果任务已经完成，则可以直接执行下个任务，避免了无用的开销。
  因此我们可以总结一下async/await：
async/await只是表示这个方法需要编译器进行特殊处理，并不代表它本身一定是异步的。
Task类中的GetAwaiter主要是给编译器用的。
  第一点我们可以用以下例子来证明，有兴趣的朋友可以自己去验证以下，以便加深理解。
//该类型包含GetAwaiter方法，且GetAwaiter()返回的类型包含三个必要条件
public class MyAwaiter : INotifyCompletion
{
public void OnCompleted(Action continuation)
{
continuation();
}
public bool IsCompleted { get; }
public void GetResult()
public MyAwaiter GetAwaiter() => new MyAwaiter();
}
  一个测试函数，注意必须返回void
public static async void AwaiterTest()
{
await new MyAwaiter();
Console.WriteLine("Done");
}
  可以看到这是完全同步进行的。
来源：https://www.cnblogs.com/hkfyf/p/14641844.html
0
投稿猜你喜欢
- 这篇文章主要介绍了shiro多验证登录代码实例及问题解决,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的
补充使用Spring Cloud Config加密功能需要下载JCE扩展，用于生成无限长度的密文。链接：http://www.oracle.- 本文实例为大家分享了java指定精确小数位的具体代码，供大家参考，具体内容如下java代码:public class App2 {publi
- 本篇紧接上一篇内容继续，还是从继承里的细节开始1.代码块初始化关于代码块的定义和使用因为之前已经进行过介绍，所以这里就不再赘述，我们所关注的
- 前言上一篇分析了事务注解的解析过程，本质上是将事务封装为切面加入到AOP的执行链中，因此会调用到MethodInceptor的实现类的inv
- 详解java中接口与抽象类的区别1.abstract class 在 Java 语言中表示的是一种继承关系，一个类只能使用一次继承关系。但是
- 下面就来分享工具类的内容：使用范围：JavaBean类对象的属性不能是数组、List、Set、Mappublic class MapBean
- 前言Zuul 是Netflix 提供的一个开源组件,致力于在云平台上提供动态路由，监控，弹性，安全等边缘服务的框架。也有很多公司使用它来作为
- 常用事件的分类Java AWT里面的事件可以简单的分为窗体事件(WindowEvent)，鼠标事件(MouseEvent)，键盘事件(Key
- 重写(Override)重写是子类对父类的允许访问的方法的实现过程进行重新编写, 返回值和形参都不能改变。即外壳不变，核心重写！重写的好处在
- 一、前言随着互联网项目前后端分离方式的流行，前端与后端交给不同的人员开发，项目沟通成本也随之提高。主要表现在WebAPI接口的沟通，Swag
- public void ProcessRequest (HttpContext context) { &n
- 1. 父工程构建1.1 Maven项目搭建环境版本JDK1.8Maven3.6+Maven模板maven-archetype-size删除父
- Java8对于LocalDateTime的序列化和反序列化这里以jackjson为例配置反序列化工具/** * 时间戳反序列化时间 * *
- 添加MyBatis的代码并修改以下部分:1.添加MyBatisConfigpackage myshop.config;import java
- 前言.NET 生态越来越好，初学的朋友也越来越多。处理同一件简单的问题，随着我们知识的积累解决问题的方法也会越来越多。开始学习一门新的语言，
- 代码思路：想要循环遍历文件夹下所有子文件夹，就要用到递归。首先判断路径是否存在：是：获取文件判断是否文件夹：是：调用自身，继续获取子文件夹下
- 前言我们知道，IOC是Spring的核心。它来负责控制对象的生命周期和对象间的关系。举个例子，我们如何来找对象的呢？常见的情况是，在路上要到
- 尝试了各种防止中文乱码的方式,但是还是乱码;最后还是细节问题导致;解决方式:以及俩种方式是百度的,我的问题不是这俩块1.在requestMa
- 前言Java的StringUtil.isEmpty(str)和"".equals(str)都是用来判断字符串是否为空的方
