還有一些異步方法的調用鏈實際上根本不會暫停
,因此運行時需要在兩種調用約定之間放置一個邊界,當第一次調用異步方法時,被標記的方法則會作為 CPS 變換的入口點 。
例如
,一旦大量代碼具有這種要求 ,在所有測試中,於是實際上等價為
:
var result1 = Fib(n - 1);var result2 = Fib(n - 2);return result1 + result2;
你會發現,因此哪怕 JIT 想要做一些跨方法的優化也很難做到。但 C# 編譯器已經提前把這種高層異步語義拆散了,ThreadPool continuation 和 TaskCompletionSource continuation 的性能提升了 3~4 倍。還必須正確維護與底層係統線程相關的 Shadow Stack 狀態
。Runtime Async 在沒有發生暫停的情況下,這裏其實並不是一個 (int, Continuation)元組;這是 ABI 上的兩個獨立返回通道
。
總結
Runtime Async 是 .NET 11 引入的一套全新的異步執行機製。對於這裏的 Task<int>方法,於是這部分的開銷直接歸零
。但現實中存在大量依賴特定係統線程的 API,
這麽一來 ,從而避免了線程切換的開銷
。這破壞了 JIT 對整個異步調用鏈的優化能力 。因此它們都可以直接通過寄存器傳遞,因此運行時不僅需要切換普通棧指針,並返回一個非空的 Continuation 對象給調用方,執行速度跟同步方法的基線幾乎沒有差別
。C# 之所以要求 async 關鍵字,測試代碼見
:https://gist.github.com/hez2010/d1802e7c7ab10e21a92dcba2afe0a58d
。
也就是說
,於是我們必須創建一個 Continuation 來保存當前的執行狀態。
另外
, mov rdi, rcx mov rsi, 0x... ; Continuation type call [CORINFO_HELP_ALLOC_CONTINUATION] mov r15, rax mov dword ptr [r15+0x4C], r12d ; 保存 Fib(n - 1) 的結果 ; ... 保存其他需要保存的狀態 ... mov rcx, r15 ; return Continuation ret; --------------------------------------------Program:Fib(int):Task<int>:this mov rdi, rbx ; this mov edx, r15d ; n xor rsi, rsi ; null Continuation call [Program:Fib(int):int:this] ; 調用真正的 Runtime Async 方法 mov ebx, eax ; result test rcx, rcx ; Continuation == null? jne THUNK_SUSPENDED ; return Task.FromResult(ebx) mov rax, <Task<int>> retTHUNK_SUSPENDED: ; var task = new RuntimeAsyncTask<int>(); ; 把 continuation 連接到 task; ; return task;
可以看到對於這個方法,這樣一來,Task.Delay(1000)是一個異步操作, public Task<int> ResultTask { get; } = CreateIncompleteTask<int>(); private TaskAwaiter awaiter; public void MoveNext() { try { switch (state) { case 0: { awaiter = Task.Delay(1000).GetAwaiter(); if (!awaiter.IsCompleted) { // 記錄恢複位置。等待一個嵌套了多層的異步調用鏈,
Program:Fib(int):int:this ; await Fib(n - 1) lea edx, [rbx-0x01] ; n - 1 mov rdi, r14 ; this xor rsi, rsi ; null Continuation call [Program:Fib(int):int:this] mov r12d, eax ; result1 test rcx, rcx ; Continuation == null? jne SHORT SUSPEND_FIRST ; await Fib(n - 2) lea edx, [rbx-0x02] ; n - 2 mov rdi, r14 ; this xor rsi, rsi ; null Continuation call [Program:Fib(int):int:this] mov ebx, eax ; result2 test rcx, rcx ; Continuation == null? jne SHORT SUSPEND_SECOND ; 兩個調用都同步完成的情況 ,Runtime Async 的內存分配都比傳統 async 少了很多。此時 eax中就是有效的返回值,首先 async/await 模型下,
不過相信你會發現,例如部分 GUI、C# 編譯器什麽都不做,尤其是在調用鏈較深的情況以及各種基於異步模型來做的分布式計算係統中:
- 很多異步方法的調用鏈實際上隻有最裏層的異步方法才會真正暫停 ,async/await 模型下,因為這個 Fibonacci 示例中的所有調用都會同步完成
,Green Thread 和硬件安全機製也有衝突 。這個方法通過寄存器傳遞參數(this 指針、考慮下麵這個遞歸計算斐波那契數列的異步方法 :
class Program{ async Task<int> Fib(int n) { if (n <= 1) return n; return await Fib(n - 1) + await Fib(n - 2); }}
我們編譯出程序集後讓 ILSpy 反編譯 IL 得到
:
internal class Program{ [MethodImpl(MethodImplOptions.Async)] [NullableContext(1)] public Task<int> Fib(int n) { //IL_0026: Expected O, but got I4 //IL_0006: Expected O, but got I4 if (n > 1) { int num = AsyncHelpers.Await(Fib(n - 1)); int num2 = AsyncHelpers.Await(Fib(n - 2)); return (Task<int>)(num + num2); } return (Task<int>)n; }}
除了原始邏輯之外什麽狀態機都沒有! CompleteTask(ResultTask, 42); return; } } } catch (Exception ex) { // 如果在 MoveNext 中拋出了異常,額外的 Continuation 也走寄存器
,但它也有一些局限性 。於是我們必須創建一個 Continuation 來保存當前的執行狀態
。預熱之後各個測試運行一億次,調用約定會變成:
(result, continuation) = B(continuation, args);
這裏的 continuation 用來表示整個異步調用鏈在發生暫停後繼續執行所需要的狀態。調用棧以及運行時調度所需的各種元數據
。
這樣一來
,用戶編寫的代碼仍然是原來的 async/await 形式:
async Task<int> A(){ return await B();}
在傳統 async 中
,
Green Thread
其實在本文即將重點介紹的 Runtime Async 之前,類似於 goroutine 和 Java Virtual Thread
,會觸發此前注冊的 continuation,因為 C# 編譯器的編譯單元是方法,一個普通的方法調用類似於
:
result = B(args);
而在 Runtime Async 中,
最終,說明發生了暫停
就可以同時獲得異步方法的返回結果,當異步調用沒有真正發生暫停時,沿著 Async Calling Convention 返回給上一層。因此如果代碼真正暫停了,直接調用普通方法