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

 更新时间:2025年08月04日 17:10:41   作者:无风听海  
async/await是C# 5.0 引入的语法糖,它基于**状态机(State Machine)**模式实现,将异步方法转换为编译器生成的状态机类,本文给大家介绍C# async await 异步编程实现机制,感兴趣的朋友一起看看吧

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

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 的创建、状态管理和结果设置
  • 提供 AwaitOnCompletedSetResultSetException 等方法

1.3.2 状态机工作流程

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

1.3.3 await 操作的执行过程

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

1.4 上下文捕获(Context Capture)

await 默认会捕获当前的 SynchronizationContextTaskScheduler

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内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • C#检查字符串是否是合法URL地址的方法

    C#检查字符串是否是合法URL地址的方法

    这篇文章主要介绍了C#检查字符串是否是合法URL地址的方法,涉及C#字符串判断的相关技巧,需要的朋友可以参考下
    2015-05-05
  • C#操作INI文件的方法详解

    C#操作INI文件的方法详解

    INI文件全称是Initialization File的缩写,即初始化文件,是windows系统的系统配置文件所采用的存储格式,统管windows的各项配置。本文介绍了C#操作INI文件的方法,需要的可以参考一下
    2022-10-10
  • 解决C#运行程序修改数据后数据表不做更新的问题

    解决C#运行程序修改数据后数据表不做更新的问题

    近日,在使用C#连接数据库的时候,对数据库中的表做更新后,在当前启动项目中去显示表数据时虽然会发生一个更新,但是在结束程序运行后再去观察数据表中的记录时发现并没有发生一个变化,所以本文给大家解决一下这个问题,需要的朋友可以参考下
    2023-08-08
  • C#实现将网址生成二维码图片方法介绍

    C#实现将网址生成二维码图片方法介绍

    这篇文章介绍了C#实现将网址生成二维码图片的方法,文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-04-04
  • C# 压榨cpu的办法(推荐)

    C# 压榨cpu的办法(推荐)

    这篇文章主要介绍了C# 压榨cpu的办法,通过修改num的值,观察cpu的核数,例如我电脑是8核的,改成8,运行时各个核都能跑满,感兴趣的朋友跟随小编一起看看吧
    2021-12-12
  • C#中嵌入SQLite数据库的简单方法

    C#中嵌入SQLite数据库的简单方法

    本文给大家介绍的是C#中嵌入SQLite数据库的简单方法,十分的方便也很实用,有需要的小伙伴可以参考下。
    2015-06-06
  • c#使用linq把多列的List转化为只有指定列的List

    c#使用linq把多列的List转化为只有指定列的List

    这篇文章主要介绍了c#使用linq把多列的List转化为只有指定列的List,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-12-12
  • C#并发容器之ConcurrentDictionary与普通Dictionary带锁性能详解

    C#并发容器之ConcurrentDictionary与普通Dictionary带锁性能详解

    这篇文章主要介绍了C#并发容器之ConcurrentDictionary与普通Dictionary带锁性能详解,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2021-04-04
  • C#中parallel.foreach实现多线程处理

    C#中parallel.foreach实现多线程处理

    Parallel.ForEach方法是C#中的一个并行循环方法,它可以并行地对一个集合进行迭代操作,本文主要介绍了C#中parallel.foreach实现多线程处理,具有一定的参考价值,感兴趣的可以了解一下
    2024-02-02
  • C#组合模式实例详解

    C#组合模式实例详解

    这篇文章主要介绍了C#组合模式,实例分析了C#实现组合模式的原理与相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-07-07

最新评论