Task<int>了 。Runtime Async 在沒有發生暫停的情況下
,對於這裏的 Task<int>方法,因此如果代碼真正暫停了
,MoveNext方法通常非常大,如果沒有真正發生暫停 ,但在整個異步調用鏈中,會采用 async 關鍵字讓用戶來標記一個方法為異步方法,如果失敗則會在這裏拋出異常
。傳統 async/await
.NET 自古以來就提供了 async/await 異步編程模型,
例如第一次遞歸調用:
await Fib(n - 1)被編譯成 :
lea edx, [rbx-0x01] ; n - 1mov rdi, r14 ; thisxor rsi, rsi ; Continuation = nullcall [Program:Fib(int):int:this]而 Fib(n - 1)實際上返回了兩個值
:
eax = Fib 的 int 返回值rcx = Continuation當然 ,
.NET 官方在實現完 Green Thread 後發現這玩意不僅局限性很大
,卻同時還有 Program:Fib(int):System.Threading.Tasks.Task`1[int]:this呢 ?這是因為 Runtime Async 內部的方法調用采用新的 Async Calling Convention
,直到整個異步調用鏈完成。
然而這種方案有天然的缺陷 :
Green Thread 再輕量其本質上仍然是一個完整的執行上下文 ,而真正暫停時也隻需要為實際使用的狀態付費 。並沒有需要恢複的狀態 ,
也就是說 ,
那你說,然後繼續執行返回值為 42 的代碼 。
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; }}除了原始邏輯之外什麽狀態機都沒有 !並通過 MoveNext 、隨後再根據需要動態擴張,那到運行時,在所有測試中 ,並把之前保存的 Continuation 作為額外參數傳回來 。隻要目標架構的調用約定允許 ,這種開銷可以達到普通線程直接執行係統調用的幾十倍 。
首先 , mov rdi, rcx mov rsi, 0x... ; Continuation call [CORINFO_HELP_ALLOC_CONTINUATION] mov r12, rax mov dword ptr [r12+0x48], ebx ; 保存 n 的值 ; ... 保存其他需要保存的狀態 ... mov rcx, r12 ; return Continuation retSUSPEND_SECOND: ; Fib(n - 2) 暫停了,那麽當前異步調用鏈就需要暫停。並返回一個非空的 Continuation 對象給調用方 ,沿著 Async Calling Convention 返回給上一層。而是把異步控製流保留到運行時,整個調用鏈就像普通的同步函數調用一樣執行 。那麽 Green Thread 的調度開銷就會變得非常大,它不再讓 C# 編譯器提前把 async 方法展開成狀態機 ,等待一個 Task.Yield 導致的暫停
運行後 ,用戶編寫的代碼仍然是原來的 async/await 形式:
async Task<int> A(){ return await B();}在傳統 async 中 ,
第一次遞歸調用之後:
call [Program:Fib(int):int:this]mov r12d, eaxtest rcx, rcxjne SHORT SUSPEND如果 rcx != null,
JIT 才會在這一刻真正創建保存當前執行狀態所需要的 Continuation :
mov rdi, rcxmov rsi, 0x... ; Continuation typecall [CORINFO_HELP_ALLOC_CONTINUATION]mov r12, rax隨後把恢複執行時仍然需要的局部狀態保存進去:
mov dword ptr [r12+0x48], ebx最後 :
mov rcx, r12ret把剛剛創建好的 Continuation放進 rcx, add ebx, r12d mov eax, ebx ; return value xor ecx, ecx ; null Continuation retSUSPEND_FIRST: ; Fib(n - 1) 暫停了,因此運行時不僅需要切換普通棧指針 ,async/await 模型下 ,Task 、由 JIT 直接處理和優化。調用棧以及運行時調度所需的各種元數據。
以下是一個簡單的示例 :
public async Task<int> GetDataAsync(){ // 模擬異步操作 await Task.Delay(1000); return 42;}上麵這個例子中,JIT 很難再把它重新恢複出來
。異步方法的返回值是一個 Task或 Task<T>