C# async await 異步編程實現(xiàn)機制詳解
一、async/await 異步編程實現(xiàn)機制
1.1 核心概念
async/await 是 C# 5.0 引入的語法糖,它基于**狀態(tài)機(State Machine)**模式實現(xiàn),將異步方法轉(zhuǎn)換為編譯器生成的狀態(tài)機類。
1.2 編譯器轉(zhuǎn)換過程
當(dāng)編譯器遇到 async 方法時,會將其轉(zhuǎn)換為一個實現(xiàn)了 IAsyncStateMachine 接口的狀態(tài)機類。
// 原始代碼
public async Task<int> GetDataAsync()
{
await Task.Delay(1000);
return 42;
}
編譯器會將其轉(zhuǎn)換為類似以下結(jié)構(gòu):
// 偽代碼:編譯器生成的狀態(tài)機
[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); // 設(shè)置返回值
}
catch (Exception e)
{
<>1__state = -2;
<>t__builder.SetException(e);
return;
}
}
public void SetStateMachine(IAsyncStateMachine stateMachine)
{
<>t__builder.SetStateMachine(stateMachine);
}
}1.3 關(guān)鍵組件解析
1.3.1 AsyncTaskMethodBuilder
- 負責(zé)管理異步方法的生命周期
- 包含
Task的創(chuàng)建、狀態(tài)管理和結(jié)果設(shè)置 - 提供
AwaitOnCompleted、SetResult、SetException等方法
1.3.2 狀態(tài)機工作流程
- 初始狀態(tài) (
<>1__state = -1):方法開始執(zhí)行 - 等待狀態(tài) (
<>1__state = 0):遇到await且任務(wù)未完成 - 完成狀態(tài) (
<>1__state = -2):方法執(zhí)行完畢或發(fā)生異常
1.3.3 await 操作的執(zhí)行過程
- 調(diào)用
GetAwaiter()獲取TaskAwaiter - 檢查
IsCompleted屬性 - 如果未完成:
- 保存當(dāng)前狀態(tài)
- 注冊 continuation 回調(diào)
- 返回控制權(quán)給調(diào)用者
- 如果已完成:繼續(xù)執(zhí)行后續(xù)代碼
1.4 上下文捕獲(Context Capture)
await 默認會捕獲當(dāng)前的 SynchronizationContext 或 TaskScheduler:
public async Task ProcessAsync()
{
// 捕獲當(dāng)前上下文
await SomeAsyncOperation();
// 回到原始上下文執(zhí)行后續(xù)代碼
UpdateUI(); // 在UI線程上執(zhí)行
}
二、死鎖產(chǎn)生的原因
2.1 同步阻塞導(dǎo)致的死鎖
最常見的死鎖場景:在同步代碼中阻塞等待異步操作完成。
// 危險代碼 - 可能導(dǎo)致死鎖
public int GetData()
{
// 死鎖!等待異步方法完成
return GetDataAsync().Result;
}
public async Task<int> GetDataAsync()
{
await Task.Delay(1000);
return 42;
}死鎖形成過程:
GetData()調(diào)用GetDataAsync()GetDataAsync()開始執(zhí)行,遇到await- 線程池線程被釋放,
GetData()在主線程阻塞等待 await完成后,需要回到原始上下文(主線程)繼續(xù)執(zhí)行- 但主線程被
Result阻塞,無法執(zhí)行 continuation - 形成死鎖
2.2 UI線程死鎖
在WinForms/WPF應(yīng)用中特別常見:
private async void Button_Click(object sender, EventArgs e)
{
// 危險:在UI事件中同步等待
var result = GetDataAsync().Result;
textBox.Text = result.ToString();
}
2.3 ASP.NET 經(jīng)典死鎖
在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 鏈?zhǔn)秸{(diào)用
public async Task<int> GetDataAsync()
{
return await GetDataAsync();
}
3.2 解決方案一:異步編程鏈
將同步方法改為異步:
// 原始同步方法
public int GetData()
{
return GetDataAsync().Result; // 死鎖風(fēng)險
}
// 改為異步方法
public async Task<int> GetDataAsync()
{
return await GetDataAsync();
}
// 調(diào)用者也需要異步
public async Task ProcessAsync()
{
var data = await GetDataAsync();
// 處理數(shù)據(jù)
}3.3 解決方案二:ConfigureAwait(false)
在類庫中使用 ConfigureAwait(false) 避免上下文捕獲:
public async Task<int> GetDataAsync()
{
// 不捕獲上下文,避免死鎖
await Task.Delay(1000).ConfigureAwait(false);
// 繼續(xù)異步操作
await AnotherAsyncOperation().ConfigureAwait(false);
return 42;
}使用場景:
- 類庫開發(fā)
- 不需要訪問UI組件的后臺操作
- ASP.NET Core 應(yīng)用
3.4 解決方案三:創(chuàng)建新線程執(zhí)行
當(dāng)必須同步調(diào)用時,使用新線程:
public int GetData()
{
// 在新線程中執(zhí)行異步方法
return Task.Run(async () => await GetDataAsync()).Result;
}四、最佳實踐
4.1 類庫開發(fā)
// 類庫中始終使用 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應(yīng)用開發(fā)
// 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;
}
}五、總結(jié)
- async/await 是基于狀態(tài)機的編譯器魔法
- 死鎖 主要由同步阻塞和上下文捕獲引起
- 最佳解決方案 是保持異步調(diào)用鏈
- 類庫開發(fā) 應(yīng)使用
ConfigureAwait(false) - 避免 在異步代碼中使用
.Result和.Wait()
遵循這些原則,可以安全高效地使用C#的異步編程模型。
到此這篇關(guān)于C# async await 實現(xiàn)機制詳解的文章就介紹到這了,更多相關(guān)c# async await內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
解決C#運行程序修改數(shù)據(jù)后數(shù)據(jù)表不做更新的問題
近日,在使用C#連接數(shù)據(jù)庫的時候,對數(shù)據(jù)庫中的表做更新后,在當(dāng)前啟動項目中去顯示表數(shù)據(jù)時雖然會發(fā)生一個更新,但是在結(jié)束程序運行后再去觀察數(shù)據(jù)表中的記錄時發(fā)現(xiàn)并沒有發(fā)生一個變化,所以本文給大家解決一下這個問題,需要的朋友可以參考下2023-08-08
C#實現(xiàn)將網(wǎng)址生成二維碼圖片方法介紹
這篇文章介紹了C#實現(xiàn)將網(wǎng)址生成二維碼圖片的方法,文中通過示例代碼介紹的非常詳細。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下2022-04-04
c#使用linq把多列的List轉(zhuǎn)化為只有指定列的List
這篇文章主要介紹了c#使用linq把多列的List轉(zhuǎn)化為只有指定列的List,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-12-12
C#并發(fā)容器之ConcurrentDictionary與普通Dictionary帶鎖性能詳解
這篇文章主要介紹了C#并發(fā)容器之ConcurrentDictionary與普通Dictionary帶鎖性能詳解,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2021-04-04
C#中parallel.foreach實現(xiàn)多線程處理
Parallel.ForEach方法是C#中的一個并行循環(huán)方法,它可以并行地對一個集合進行迭代操作,本文主要介紹了C#中parallel.foreach實現(xiàn)多線程處理,具有一定的參考價值,感興趣的可以了解一下2024-02-02

