Async Programming - 1 async-await 糖的本质（2）

上一篇讲了这么多，其实说的就是一个事，return会被编译器重写成SetResult，所以如果我们的异步函数返回的是一个Task<int>，代码就要改成这样：

using System;
using System.Runtime.CompilerServices;
using System.Threading.Tasks;

namespace StateMachineDemo
{
class Program
{
static void Main(string[] args)
{
Console.WriteLine(FooAsync2().Result);
}

public static async Task<int> FooAsync()
{
await Task.Delay(10000);
return 42;
}

public static Task<int> FooAsync2()
{
var stateMachine = new FooAsyncStateMachine();
stateMachine.MethodBuilder = new AsyncTaskMethodBuilder<int>();

stateMachine.MethodBuilder.Start(ref stateMachine);

return stateMachine.MethodBuilder.Task;
}

public struct FooAsyncStateMachine : IAsyncStateMachine
{
public AsyncTaskMethodBuilder<int> MethodBuilder;
public void MoveNext()
{
MethodBuilder.SetResult(42);
}

public void SetStateMachine(IAsyncStateMachine stateMachine)
{
throw new NotImplementedException();
}
}
}
}

函数的返回值换成了Task<int>，里面返回MethodBuilder.Task，原来的AsyncVoidMethodBuilder对应换成了AsyncTaskMethodBuilder<int>，SetResult这里面return了一个值，就是这样。

下面来加点料，前面说的都是平凡的异步方法，现在我们真正的来在方法里面await一个东西，比如await Task.Delay(10000);

public static async Task<int> FooAsync()
{
await Task.Delay(10000);
return 42;
}

这个时候状态机就要真正的起作用了，这个代码有两个状态——await执行之前到开始执行、await执行之后，也就是说对于一个有n个await函数，他就有n+1个状态，分别是从开始到第1个await，第i到i+1个await，第n个await到结束。

对于我们的代码，不妨用一个int来表示状态，0是第一个状态，1是第二个状态，我们先在MoveNext里面把框架写好：

public struct FooAsyncStateMachine : IAsyncStateMachine
{
public AsyncTaskMethodBuilder<int> MethodBuilder;

public int State;

public void MoveNext()
{
if (State == 0)
{
//await之前以及开始await
return;
}

if (State == 1)
{
//await之后
MethodBuilder.SetResult(42);
return;
}
}

public void SetStateMachine(IAsyncStateMachine stateMachine)
{
throw new NotImplementedException();
}
}

好了现在看State==0的时候，这里面await之前没有代码，所以我们只需要启动Task.Delay(10000)，首先是Task.Delay(10000);表达式的求值：

public void MoveNext()
{
if (State == 0)
{
Task.Delay(10000);
return;
}

if (State == 1)
{
//await之后
MethodBuilder.SetResult(42);
return;
}
}

这样还不行，我们没法确定Task.Delay什么时候完成，编译器在这里是这样实现的：Task.Delay(10000);返回的是一个Task，对他调用GetAwaiter，拿到awaiter：

public void MoveNext()
{
if (State == 0)
{
TaskAwaiter awaiter = Task.Delay(10000).GetAwaiter();
//注册回调什么的
return;
}

if (State == 1)
{
//await之后
MethodBuilder.SetResult(42);
return;
}
}

如果我们直接这么写

if (State == 0)
{
TaskAwaiter awaiter = Task.Delay(10000).GetAwaiter();
awaiter.GetResult();
return;
}

GetResult是个阻塞调用，卡住控制流就不好了，所以GetResult要在Task确定完成的时候，也就是State==1的时候（State被谁设为1我们之后讲），也就是在第二个if里面，GetResult

if (State == 1)
{
//await之后
awaiter.GetResult();
MethodBuilder.SetResult(42);
return;
}

然而你会发现TaskAwaiter的作用域是前一个if块，在这里我们访问不到，所以TaskAwaiter也应该作为类成员而不是方法内的局部变量，顺便说这东西也是一个struct，同样是我们不希望有额外的堆操作开销，最后改好的StateMachine是这样

public struct FooAsyncStateMachine : IAsyncStateMachine
{
public AsyncTaskMethodBuilder<int> MethodBuilder;

public int State;

private TaskAwaiter awaiter;

public void MoveNext()
{
if (State == 0)
{
awaiter = Task.Delay(10000).GetAwaiter();
return;
}

if (State == 1)
{
//await之后
awaiter.GetResult();
MethodBuilder.SetResult(42);
return;
}
}

public void SetStateMachine(IAsyncStateMachine stateMachine)
{
throw new NotImplementedException();
}
}

还没完，第一个if里面是已经让awaiter跑起来了，还需要一个机制让它在完成的时候State变成1，以及让他调用MoveNext，走第二个if，继续后面的控制流。这里有一个简单的优化，我们先检测task有没有完成，如果完成了，那么把State设为1，直接goto到第二个if，如果没有的话，再注册让他完成时调用MoveNext的相关东西：

if (State == 0)
{
awaiter = Task.Delay(10000).GetAwaiter();
if (awaiter.IsCompleted)
{
State = 1;
goto state1;
}
else
{
//task还没完
}
return;
}
state1:
if (State == 1)
{
//await之后
awaiter.GetResult();
MethodBuilder.SetResult(42);
return;
}
}

如果task还没完，我们同样需要把State设为1，这样当然完了的时候，一个什么东西继续调用MoveNext，就能直接执行第二个if块的内容了。关于注册完成时调用MoveNext，这里有个API函数叫做

if (State == 0)
{
awaiter = Task.Delay(10000).GetAwaiter();
if (awaiter.IsCompleted)
{
State = 1;
goto state1;
}
else
{
State = 1;
MethodBuilder.AwaitUnsafeOnCompleted(ref awaiter, ref this);
}
return;
}

StateMachine.AwaitUnsafeOnCompleted，还有一个函数叫AwaitOnCompleted，具体里面有什么差别我也不是很懂，总之编译器重写的时候用的是这个，两个参数，一个是awaiter，要等待完成的东西，一个this，完成之后调用this的MoveNext，逻辑很清楚，可以看到这里用了ref，为了把参数都转移到堆上，因为之后方法就返回栈就回退了，栈上的东西都会销毁。

看似什么都已经好了（其实并没有），我们运行一下看看：





哎，挂在了这里，这里我们应该写成这样：

public void SetStateMachine(IAsyncStateMachine stateMachine)
{
MethodBuilder.SetStateMachine(stateMachine);
}

为什么一个method builder要SetStateMachine呢，回去看我们当初写的代码：

public static Task<int> FooAsync2()
{
var stateMachine = new FooAsyncStateMachine();
stateMachine.MethodBuilder = new AsyncTaskMethodBuilder<int>();

stateMachine.MethodBuilder.Start(ref stateMachine);

return stateMachine.MethodBuilder.Task;
}

这里MethodBuilder是获得了一个ref，引用到到栈上的stateMachine，C#的ref你可以理解为指针：最开始，MethodBuilder里面有一个指向栈上stateMachine的指针，这很好，但是前面一步我们用MethodBuilder.AwaitUnsafeOnCompleted(ref awaiter, ref this); 调用把state machine本体转移到了堆上，所以原来MethodBuilder里面指向栈上StateMachine的引用（指针）就无效了，所以我们需要给MethodBuilder一个新的堆上的stateMachine的引用，让他持有正确的状态机。

现在都好了，我在if(State==1)那里下个断点，我们跑一下代码，看看回调是怎么发生的：





代码停在了这里，看调用堆栈，是另一条独立的线程继续调用了MoveNext，从Delay产生作用的TimerCallback一直向上，最后调用了MoveNext，值得一提的是，主线程被某种同步机制卡住了，因为那时候FooAsync2的结果还没有return出来给它打印，看看并行堆栈监视





的确是一条独立的线程调用了MoveNext，主线程也被卡住了。

总结一下，编译器会把第i个await重写为两个部分，一个是在状态i里面的GetAwaiter、测试IsCompleted，有的话直接跳第i+1个状态、没有的话注册回调，另一个是在状态i+1里面的GetResult。

就这么多，后面复杂的东西，比如AwaitUnsafeOnComplete为什么Unsafe，以及主线程被卡住的机制，我还不怎么懂，这篇主要是讲一下编译器怎么重写最简单的await，大概思路是这样，至于更复杂的await，比如if块里的，try-catch里的，不是很懂也就不说了。