C#的异步编程从APM异步编程模型和EAP基于事件的异步模式演进到Task和async/await。当前模型在易用性和性能之间取得了较好的平衡但其底层机制值得深入理解。一、Task异步操作的基本单元Task表示一个异步操作可以处于Created、WaitingForActivation、Running、RanToCompletion、Faulted或Canceled状态。csharpTaskint task Task.Run(() { return ComputeResult(); });Task在底层由TaskScheduler调度默认使用线程池执行。TaskScheduler控制任务在哪个线程上执行默认在线程池上执行。自定义TaskScheduler可以实现在单线程上下文中按顺序执行任务。Task内部维护了状态字段、异常信息和继续执行的委托列表。TaskCompletionSourceT手动控制Task的完成状态适用于将回调API转换为Task。csharpvar tcs new TaskCompletionSourceint(); tcs.SetResult(42); int result await tcs.Task; // 立即完成二、async/await的状态机生成async关键字标记的方法在编译时被重写为状态机。编译器生成一个实现IAsyncStateMachine的结构体将方法中的代码分解为多个状态。csharppublic async Taskint GetDataAsync() { var data await FetchDataAsync(); return data.Length; }编译器生成的代码类似于csharpprivate struct GetDataAsyncd__0 : IAsyncStateMachine { public int 1__state; public AsyncTaskMethodBuilderint t__builder; public int data5__1; private TaskAwaiterint u__1; public void MoveNext() { // 根据状态跳转到对应代码段 // 等待完成后恢复执行 } }状态机在MoveNext中根据state变量跳转到不同代码段。await表达式在底层调用GetAwaiter()获取等待器注册完成回调当前状态机暂停并返回。等待器完成时线程池调用MoveNext恢复执行。三、同步上下文线程切换的抽象SynchronizationContext是线程间的调度抽象允许异步操作在特定上下文如UI线程中恢复。csharp// WPF/WinForms中 var context SynchronizationContext.Current; // UI线程上下文 await Task.Run(() Compute()); // 在线程池执行 // 自动回到UI线程继续执行ConfigureAwait(false)跳过捕获同步上下文避免尝试回到原始线程。csharpawait httpClient.GetStringAsync(url).ConfigureAwait(false);在UI应用中ConfigureAwait(false)避免死锁UI线程等待异步操作完成异步操作尝试回到UI线程导致死锁。在类库中默认使用ConfigureAwait(false)由上层决定是否需要上下文。四、ValueTask减少分配TaskT是引用类型每次异步操作分配堆对象。高频异步操作如循环中的网络请求产生大量Task对象增加GC压力。ValueTaskT是值类型包装了三种可能状态成功结果、Task实例、IValueTaskSource实例。对于同步完成或结果已知的操作ValueTask避免堆分配。csharppublic ValueTaskint GetCachedValueAsync() { if (_cacheValid) { return new ValueTaskint(_cacheValue); // 不分配Task } return new ValueTaskint(FetchValueAsync()); // 复用Task }ValueTaskT只能被await一次且不能跨异步操作复用。await后获取结果ValueTask的内部状态可能被释放。五、异步流IAsyncEnumerableC# 8引入异步流支持异步生成序列。csharpasync IAsyncEnumerableint GenerateSequence() { for (int i 0; i 10; i) { await Task.Delay(100); yield return i; } } await foreach (var item in GenerateSequence()) { Console.WriteLine(item); }IAsyncEnumerableT的枚举器是IAsyncEnumeratorT其MoveNextAsync()返回ValueTaskbool允许异步等待下一个元素。await foreach在编译时展开为状态机类似async方法。六、异步方法的异常处理异步方法中的异常在await时传播而非在调用时。csharpvar task MayThrowAsync(); // 不抛异常返回Task await task; // 异常在此处抛出未处理的异常在Task中被捕获最终抛给UnobservedTaskException事件。在.NET Core/.NET 5中未观察到的Task异常默认触发进程崩溃不同版本的默认处理策略不同但早期.NET Framework默认不抛出这导致异常被静默忽略。csharpTaskScheduler.UnobservedTaskException (sender, args) { // 记录异常 args.SetObserved(); // 阻止崩溃早期版本行为 };在ASP.NET Core中未处理的异步异常可能导致请求失败但不会导致进程崩溃除非HostBuilder配置了不同的异常处理策略。七、性能考量与最佳实践在类库中使用ConfigureAwait(false)除非需要特定的同步上下文。避免在同步方法中调用异步方法死锁风险。避免使用.Result或.Wait()阻塞异步方法容易导致死锁且丢失异常信息。使用ValueTask处理高频异步操作但注意其一次性限制。在循环中避免重复创建Task使用Task.WhenAll批量处理。使用CancellationToken支持取消操作避免资源浪费。八、小结C#的异步编程模型建立在Task和状态机生成之上。async/await将异步代码的编写复杂度降到接近同步代码的水平但底层的状态机转换、同步上下文捕获和Task调度机制决定了其性能特征。理解这些机制有助于选择合适异步模式并避免常见陷阱。
C#的异步编程从APM异步编程模型和EAP基于事件的异步模式演进到Task和async/await。当前模型在易用性和性能之间取得了较好的平衡但其底层机制值得深入理解。一、Task异步操作的基本单元Task表示一个异步操作可以处于Created、WaitingForActivation、Running、RanToCompletion、Faulted或Canceled状态。csharpTaskint task Task.Run(() { return ComputeResult(); });Task在底层由TaskScheduler调度默认使用线程池执行。TaskScheduler控制任务在哪个线程上执行默认在线程池上执行。自定义TaskScheduler可以实现在单线程上下文中按顺序执行任务。Task内部维护了状态字段、异常信息和继续执行的委托列表。TaskCompletionSourceT手动控制Task的完成状态适用于将回调API转换为Task。csharpvar tcs new TaskCompletionSourceint(); tcs.SetResult(42); int result await tcs.Task; // 立即完成二、async/await的状态机生成async关键字标记的方法在编译时被重写为状态机。编译器生成一个实现IAsyncStateMachine的结构体将方法中的代码分解为多个状态。csharppublic async Taskint GetDataAsync() { var data await FetchDataAsync(); return data.Length; }编译器生成的代码类似于csharpprivate struct GetDataAsyncd__0 : IAsyncStateMachine { public int 1__state; public AsyncTaskMethodBuilderint t__builder; public int data5__1; private TaskAwaiterint u__1; public void MoveNext() { // 根据状态跳转到对应代码段 // 等待完成后恢复执行 } }状态机在MoveNext中根据state变量跳转到不同代码段。await表达式在底层调用GetAwaiter()获取等待器注册完成回调当前状态机暂停并返回。等待器完成时线程池调用MoveNext恢复执行。三、同步上下文线程切换的抽象SynchronizationContext是线程间的调度抽象允许异步操作在特定上下文如UI线程中恢复。csharp// WPF/WinForms中 var context SynchronizationContext.Current; // UI线程上下文 await Task.Run(() Compute()); // 在线程池执行 // 自动回到UI线程继续执行ConfigureAwait(false)跳过捕获同步上下文避免尝试回到原始线程。csharpawait httpClient.GetStringAsync(url).ConfigureAwait(false);在UI应用中ConfigureAwait(false)避免死锁UI线程等待异步操作完成异步操作尝试回到UI线程导致死锁。在类库中默认使用ConfigureAwait(false)由上层决定是否需要上下文。四、ValueTask减少分配TaskT是引用类型每次异步操作分配堆对象。高频异步操作如循环中的网络请求产生大量Task对象增加GC压力。ValueTaskT是值类型包装了三种可能状态成功结果、Task实例、IValueTaskSource实例。对于同步完成或结果已知的操作ValueTask避免堆分配。csharppublic ValueTaskint GetCachedValueAsync() { if (_cacheValid) { return new ValueTaskint(_cacheValue); // 不分配Task } return new ValueTaskint(FetchValueAsync()); // 复用Task }ValueTaskT只能被await一次且不能跨异步操作复用。await后获取结果ValueTask的内部状态可能被释放。五、异步流IAsyncEnumerableC# 8引入异步流支持异步生成序列。csharpasync IAsyncEnumerableint GenerateSequence() { for (int i 0; i 10; i) { await Task.Delay(100); yield return i; } } await foreach (var item in GenerateSequence()) { Console.WriteLine(item); }IAsyncEnumerableT的枚举器是IAsyncEnumeratorT其MoveNextAsync()返回ValueTaskbool允许异步等待下一个元素。await foreach在编译时展开为状态机类似async方法。六、异步方法的异常处理异步方法中的异常在await时传播而非在调用时。csharpvar task MayThrowAsync(); // 不抛异常返回Task await task; // 异常在此处抛出未处理的异常在Task中被捕获最终抛给UnobservedTaskException事件。在.NET Core/.NET 5中未观察到的Task异常默认触发进程崩溃不同版本的默认处理策略不同但早期.NET Framework默认不抛出这导致异常被静默忽略。csharpTaskScheduler.UnobservedTaskException (sender, args) { // 记录异常 args.SetObserved(); // 阻止崩溃早期版本行为 };在ASP.NET Core中未处理的异步异常可能导致请求失败但不会导致进程崩溃除非HostBuilder配置了不同的异常处理策略。七、性能考量与最佳实践在类库中使用ConfigureAwait(false)除非需要特定的同步上下文。避免在同步方法中调用异步方法死锁风险。避免使用.Result或.Wait()阻塞异步方法容易导致死锁且丢失异常信息。使用ValueTask处理高频异步操作但注意其一次性限制。在循环中避免重复创建Task使用Task.WhenAll批量处理。使用CancellationToken支持取消操作避免资源浪费。八、小结C#的异步编程模型建立在Task和状态机生成之上。async/await将异步代码的编写复杂度降到接近同步代码的水平但底层的状态机转换、同步上下文捕获和Task调度机制决定了其性能特征。理解这些机制有助于选择合适异步模式并避免常见陷阱。
