C# async await 异步编程实现机制详解

2025-08-04 21:50
文章标签 c# 实现 详解 编程 异步 机制 .net async await netcore

本文主要是介绍C# async await 异步编程实现机制详解，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

《C#asyncawait异步编程实现机制详解》async/await是C#5.0引入的语法糖,它基于**状态机（StateMachine）**模式实现,将异步方法转换为编译器生成的状态机类,本...

一、async/await js异步编程实现机制

1.1 核心概念

async/await 是 C# 5.0 引入的语法糖，它基于**状态机（State MAChine）**模式实现，将异步方法转换为编译器生成的状态机类。

1.2 编译器转换过程

当编译器遇到 async 方法时，会将其转换为一个实现了 IAsyncStateMachine 接口的状态机类。

// 原始代码
public async Task<int> GetDataAsync()
{
    await Task.Delay(1000);
    return 42;
}

编译器会将其转换为类似以下结构：

// 伪代码：编译器生成的状态机
[CompilerGenerated]
private sealed class <GetDataAsync>d__1 : IAsyncStateMachine
{
    public int <>1__state;
    public AsyncTaskMethodBuilder<int> <>t__builder;
    public YourClass <>4__this;
    private TaskAwaiter <>u__1;
    public void MoveNext()
    {
        int num = <>1__state;
        try
        {
            TaskAwaiter awaiter;
            if (num != 0)
            {
                awaiter = Task.Delay(1000).GetAwaiter();
                if (!awaiter.IsCompleted)
                {
                    <>1__state = 0;
                    <>u__1 = awaiter;
                    <>t__builder.AwaitOnCompleted(ref awaiter, ref this);
                    return;
                }
            }
            else
            {
                awaiter = <>u__1;
                <>u__1 = default(TaskAwaiter);
                <>1__state = -1;
            }
            awaiter.GetResult(); // 清理异常
            <>t__builder.SetResult(42); // 设置返回值
        }
        catch (Exception e)
        {
            <>1__state = -2;
            <>t__builder.SetException(e);
            return;
        }
    }
    public void SetStateMachine(IAsyncStateMachine stateMachine)
    {
        <>t__builder.SetStateMachine(stateMachine);
    }
}

1.3 关键组件解析

1.3.1 AsyncTaskMethodBuilder

  • 负责管理异步方法的生命周期
  • 包含 Task 的创建、状态管理和结果设置
  • 提供 AwaitOnCompleted、SetResult、SetException 等方法

1.3.2 状态机工作流程

  1. 初始状态 (<>1__state = -1)：方法开始执行
  2. 等待状态 (<>1__state = 0)：遇到 await 且任务未完成
  3. 完成状态 (<>1__state = -2)：方法执行完毕或发生异常

1.3.3 await 操作的执行过程

  1. 调用 GetAwaiter() 获取 TaskAwaiter
  2. 检查 IpythonsCompleted 属性
  3. 如果未完成：
    • 保存当前状态
    • 注册 continuation 回调
    • 返回控制权给调用者
  4. 如果已完成：继续执行后续代码

1.4 上下文捕获（Context Capture）

await 默认会捕获当前的 SynchronizationContext 或 TaskScheduler：

public async Task ProcessAsync()
{
    // 捕获当前上下文
    await SomeAsyncOperation();
    // 回到原始上下文执行后续代码
    UpdateUI(); // 在UI线程上执行
}

二、死锁产生的原因

2.1 同步阻塞导致的死锁

最常见的死锁场景：在同步代码中阻塞等待异步操作完成。

// 危险代码 - 可能导致死锁
public int GetData()
{
    // 死锁！等待异步方法完成
    return GetDataAsync().Result;
}
public async Task<int> GetDataAsync()
{
    await Task.Delay(1000);
    return 42;
}

死锁形成过程：

  1. GetData() 调用 GetDataAsync()
  2. GetDataAsync() 开始执行，遇到 await
  3. 线程池线程被释放，GetData() 在主线程阻塞等待
  4. await 完成后，需要回到原始上下文（主线程）继续执行
  5. 但主线程被 Result 阻塞，无法执行 continuation
  6. 形成死锁

2.2 UI线程死锁

在WinForms/wpF应用中特别常见：

private async void Button_Click(object sender, EventArgs e)
{
    // 危险：在UI事件中同步等待
    var result = GetDataAsync().Result;
    textBox.Text = result.ToString();
}

2.3 ASP.NET 经典死锁

在ASP.NET Framework中：

public ActionResult GetData()
{
    // 可能死锁
    var data = GetDataAsync().Result;
    return json(data);
}

三、死锁解决方案

3.1 根本原则：避免同步阻塞

错误做法：

// ❌ 避免使用
var result = DoAsync().Result;
var result = DoAsync().Wait();
var result = DoAsync().GetAwaiter().GetResult();

正确做法：

// ✅ 使用 async/await 链式调用
public async Task<int> GetDataAsync()
{
    return await GetDataAsync();
}

3.2 解决方案一：异步编程链

将同步方法改为异步：

// 原始同步方法
public int GetData()
{
    return GetDataAsync().Result; // 死锁风险
}
// 改为异步方法
public async Task<int> GetDataAsync()
{
    return await GetDataAsync();
}
// 调用者也需要异步
public async Task ProcessAsync()
{
    var data = await GetDataAsync();
    // 处理数据
}

3.3 解决方案二：ConfigureAwait(false)

在类库中使用 ConfigureAwait(false) 避免上下文捕获：

public async Task<int> GetDataAsync()
{
    // 不捕获上下文，避免死锁
    await Task.Delay(1000).ConfigureAwait(false);
    // 继续异步操作
    await AnotherAsyncOperation().ConfigureAwait(false);
    return 42;
}

使用场景：

  • 类库开发
  • 不需要访问UI组件的后台操作
  • ASP.NET Core 应用

3.4 解决方案三：创建新线程执行

当必须同步调用时，使用新线程：

public int GetData()
{
    // 在新线程中执行异步方法
    return Task.Run(async () => await GetDataAsync()).Result;
}

四、最佳实践

4.1 类库开发

// 类库中始终使用 ConfigureAwait(false)
public async Task<ServiceResult> CallServiceAsync()
{
    var response = await httpClient.GetAsync(url)
        .ConfigureAwait(false);
    var content = await response.Content.ReadAsStringAsync()
        .ConfigureAwait(false);
    return JsonConvert.DeserializeObject<ServiceResult>(content);
}

4.2 UI应用开发

// UI事件处理保持异步
private async void Button_Click(object sender, EventArgs e)
{
    try
    {
        button.Enabled = false;
        var result = await GetDataAsync(); // 不使用 .Result
        textBox.Text = result.ToString();
    }
    catch (Exception ex)
    {
        MessageBox.Show(ex.Message);
    }
    finally
    {
        button.Enabled = true;
    }
}

4.3 异步Main方法

// .NET 4.7.1+ 支持 async Main
static async Task<int> Main(string[] args)
{
    try
    {
        await ProcessAsync();
        return 0;
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.Message);
        return 1;
    }
}

五、总结

  1. async/await 是基于状态机的编译器魔法
  2. 死锁 主要由同步阻塞和上下文捕获引起
  3. 最佳解决方案 是保持异步调用链
  4. 类库开发 应使用 ConfigureAwait(false)
  5. 避免 在异步代码中使用 .Result 和 .Wait()

遵循这些原则，可以安全高效地使用C#的异步编程模型。

到此这篇关于C# async await 实现机制详解的文章就介绍到这了,更多相关c# async await内容请搜索China编程(www.chinasem.cn)以前的编程文章或继续浏览下面的相关文章希望大家以后多多支持编程javascriptChina编程(www.chinasem.cn)！

这篇关于C# async await 异步编程实现机制详解的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1155593。

相关文章

Java StringBuilder 实现原理全攻略

Java StringBuilder 实现原理全攻略

《JavaStringBuilder实现原理全攻略》StringBuilder是Java提供的可变字符序列类,位于java.lang包中,专门用于高效处理字符串的拼接和修改操作,本文给大家介绍Ja... 目录一、StringBuilder 基本概述核心特性二、StringBuilder 核心实现2.1 内部
阅读更多...
Android实现图片浏览功能的示例详解(附带源码)

Android实现图片浏览功能的示例详解(附带源码)

《Android实现图片浏览功能的示例详解(附带源码)》在许多应用中,都需要展示图片并支持用户进行浏览,本文主要为大家介绍了如何通过Android实现图片浏览功能,感兴趣的小伙伴可以跟随小编一起学习一... 目录一、项目背景详细介绍二、项目需求详细介绍三、相关技术详细介绍四、实现思路详细介绍五、完整实现代码
阅读更多...
SpringBoot AspectJ切面配合自定义注解实现权限校验的示例详解

SpringBoot AspectJ切面配合自定义注解实现权限校验的示例详解

《SpringBootAspectJ切面配合自定义注解实现权限校验的示例详解》本文章介绍了如何通过创建自定义的权限校验注解,配合AspectJ切面拦截注解实现权限校验,本文结合实例代码给大家介绍的非... 目录1. 创建权限校验注解2. 创建ASPectJ切面拦截注解校验权限3. 用法示例A. 参考文章本文
阅读更多...
Java中字符编码问题的解决方法详解

Java中字符编码问题的解决方法详解

《Java中字符编码问题的解决方法详解》在日常Java开发中,字符编码问题是一个非常常见却又特别容易踩坑的地方,这篇文章就带你一步一步看清楚字符编码的来龙去脉,并结合可运行的代码,看看如何在Java项... 目录前言背景：为什么会出现编码问题常见场景分析控制台输出乱码文件读写乱码数据库存取乱码解决方案统一使
阅读更多...
SpringBoot集成redisson实现延时队列教程

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配
阅读更多...
PHP轻松处理千万行数据的方法详解

PHP轻松处理千万行数据的方法详解

《PHP轻松处理千万行数据的方法详解》说到处理大数据集,PHP通常不是第一个想到的语言,但如果你曾经需要处理数百万行数据而不让服务器崩溃或内存耗尽,你就会知道PHP用对了工具有多强大,下面小编就... 目录问题的本质php 中的数据流处理：为什么必不可少生成器：内存高效的迭代方式流量控制：避免系统过载一次性
阅读更多...
Python的Darts库实现时间序列预测

Python的Darts库实现时间序列预测

《Python的Darts库实现时间序列预测》Darts一个集统计、机器学习与深度学习模型于一体的Python时间序列预测库,本文主要介绍了Python的Darts库实现时间序列预测,感兴趣的可以了解... 目录目录一、什么是 Darts？二、安装与基本配置安装 Darts导入基础模块三、时间序列数据结构与
阅读更多...
Python使用FastAPI实现大文件分片上传与断点续传功能

Python使用FastAPI实现大文件分片上传与断点续传功能

《Python使用FastAPI实现大文件分片上传与断点续传功能》大文件直传常遇到超时、网络抖动失败、失败后只能重传的问题,分片上传+断点续传可以把大文件拆成若干小块逐个上传,并在中断后从已完成分片继... 目录一、接口设计二、服务端实现（FastAPI）2.1 运行环境2.2 目录结构建议2.3 serv
阅读更多...
C#实现千万数据秒级导入的代码

C#实现千万数据秒级导入的代码

《C#实现千万数据秒级导入的代码》在实际开发中excel导入很常见,现代社会中很容易遇到大数据处理业务,所以本文我就给大家分享一下千万数据秒级导入怎么实现,文中有详细的代码示例供大家参考,需要的朋友可... 目录前言一、数据存储二、处理逻辑优化前代码处理逻辑优化后的代码总结前言在实际开发中excel导入很
阅读更多...
SpringBoot+RustFS 实现文件切片极速上传的实例代码

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot？二、环境准备与部署2.1 安装 RustF
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2