当前位置：首页 > news >正文

揭开 C#中的异步/等待：隐藏状态机

news 2026/5/11 22:55:39

引言

作为.NET开发者，我们每天都在使用async和await关键字来编写异步代码。这些关键字让异步代码看起来像同步代码一样直观易读，同时避免了回调地狱的问题。但你是否好奇过，当C#编译器遇到async方法时，底层究竟发生了什么魔法？本文将基于微软官方文档，深入剖析async/await背后的秘密——编译器生成的状态机机制。

正文

异步/等待解决了什么问题？

在传统同步I/O操作中（如文件读取或Web API调用），调用线程会被阻塞直到操作完成。这在UI应用中会导致界面冻结，在服务器应用中则造成线程资源的浪费。async/await通过非阻塞的异步操作解决了这些问题，同时保持了代码的线性结构和可读性。

编译器的转换：从方法到状态机

当你用async标记一个方法时，C#编译器并不会直接执行你的代码。相反，它会将该方法重写为一个状态机结构体。这个结构体实现了IAsyncStateMachine接口，包含以下关键部分：

当前状态（整数，表示执行暂停的位置）
捕获的局部变量和参数（提升为字段以便在await之间保持状态）
方法构建器（如AsyncTaskMethodBuilder用于Task返回）

原始方法被转换为一个存根(stub)方法：它在栈上创建状态机实例，初始化并启动它。而你的主要代码逻辑则被移动到状态机的MoveNext()方法中，通过状态值和switch语句实现执行点的跳转。

特别重要的是：如果异步方法同步完成（所有等待的操作已经完成），状态机将保留在栈上，不会发生堆分配。只有当真正的await暂停执行时，结构体才会被装箱到堆中。

一个简单示例

考虑以下异步方法：

public async Task<int> DownloadDataAsync(string url)
{using var client = new HttpClient();string data = await client.GetStringAsync(url);return data.Length;
}

在编译时，编译器会将该方法重写为状态机结构体，并生成一个存根方法替换原始方法签名。方法体被拆分并移入状态机的MoveNext()方法中，按状态组织。

运行时调用流程：

生成的存根创建状态机实例（初始在栈上）
初始化状态机（状态设为-1，捕获必要参数/局部变量）
调用MoveNext()开始执行

在MoveNext()内部：

执行从当前状态开始，直到遇到await
如果等待的任务已完成，继续同步执行（快速路径，无堆分配）
如果任务未完成，注册继续回调，立即返回控制（非阻塞），并暂停执行
任务完成后，继续回调会再次调用MoveNext()，从await点恢复执行

编译器生成的状态机

以下是编译器生成的状态机简化伪代码（基于Release模式下的反编译结果）：

private struct <DownloadDataAsync>d__1 : IAsyncStateMachine
{public int <>1__state;                      // 状态：-1=开始，0=等待中，-2=完成public AsyncTaskMethodBuilder<int> <>t__builder;public string url;                          // 捕获的参数private string <data>5__2;                  // 提升的局部变量private HttpClient <client>5__3;            // using变量也被提升private void MoveNext(){int num = this.<>1__state;try{if (num == -1)                          // 初始执行{this.<client>5__3 = new HttpClient();Task<string> getTask = this.<client>5__3.GetStringAsync(this.url);var awaiter = getTask.GetAwaiter();if (!awaiter.IsCompleted){this.<>1__state = 0;            // 标记为等待中this.<>t__builder.AwaitUnsafeOnCompleted(ref awaiter, ref this);return;                         // 在此暂停 - 继续回调稍后调用MoveNext}// 已完成时的快速路径this.<data>5__2 = awaiter.GetResult();}else                                    // num == 0 → await后恢复{this.<data>5__2 = /* awaiter.GetResult()逻辑 */;}// await之后的代码int result = this.<data>5__2.Length;// 清理this.<client>5__3?.Dispose();// 设置最终结果this.<>1__state = -2;this.<>t__builder.SetResult(result);}catch (Exception exception){this.<>1__state = -2;this.<>t__builder.SetException(exception);}}void IAsyncStateMachine.MoveNext() => MoveNext();// SetStateMachine(...)为简洁省略
}

原始方法被转换为类似这样的存根：

public Task<int> DownloadDataAsync(string url)
{var stateMachine = new <DownloadDataAsync>d__1();stateMachine.<>t__builder = AsyncTaskMethodBuilder<int>.Create();stateMachine.url = url;stateMachine.<>1__state = -1;stateMachine.<>t__builder.Start(ref stateMachine);return stateMachine.<>t__builder.Task;
}