程實(shí)現(xiàn)原理：從狀態(tài)機(jī)到異步編程的底層機(jī)制)
1. 從“為什么需要協(xié)程”說(shuō)起如果你寫過(guò)一段時(shí)間C#尤其是在處理UI響應(yīng)、網(wǎng)絡(luò)請(qǐng)求或者游戲邏輯時(shí)大概率會(huì)對(duì)“線程阻塞”這個(gè)詞深惡痛絕。想象一個(gè)場(chǎng)景你的WPF或WinForms界面上有個(gè)按鈕點(diǎn)擊后需要從遠(yuǎn)程服務(wù)器下載一個(gè)文件。如果你用最直接的Thread或者Task.Run去執(zhí)行一個(gè)同步的下載方法UI線程就會(huì)被卡住界面“凍住”用戶會(huì)看到一個(gè)轉(zhuǎn)圈圈的鼠標(biāo)體驗(yàn)極差。這就是典型的“阻塞式”編程帶來(lái)的問題。為了解決這個(gè)問題我們引入了異步編程模型async/await。它讓代碼看起來(lái)是順序執(zhí)行的但底層卻不會(huì)阻塞調(diào)用線程。這背后的大功臣就是“協(xié)程”Coroutine的思想。雖然C#官方文檔里更常提“狀態(tài)機(jī)”和“異步方法”但其核心機(jī)制——能夠暫停和恢復(fù)執(zhí)行流程——正是協(xié)程的典型特征。在Unity游戲開發(fā)中“協(xié)程”更是被直接作為一個(gè)關(guān)鍵字IEnumerator配合yield return來(lái)使用用于實(shí)現(xiàn)跨幀的延時(shí)邏輯比如等待幾秒后執(zhí)行某個(gè)動(dòng)作而不用寫一堆令人頭疼的計(jì)時(shí)器回調(diào)。所以當(dāng)我們?cè)贑#語(yǔ)境下討論“用純C#實(shí)現(xiàn)協(xié)程”時(shí)我們探討的是一種更底層、更可控的流程控制機(jī)制。它不像async/await那樣深度綁定于語(yǔ)言和編譯器也不像Unity的協(xié)程那樣依賴于游戲引擎的生命周期。我們自己實(shí)現(xiàn)的協(xié)程能讓我們更透徹地理解“暫停與恢復(fù)”的本質(zhì)明白協(xié)程與線程的根本區(qū)別從而在那些無(wú)法或不便使用async/await的特定場(chǎng)景比如某些嵌入式環(huán)境、自定義腳本引擎或高性能服務(wù)器核心邏輯中多一種優(yōu)雅的解決方案。2. 協(xié)程的核心可暫停與恢復(fù)的執(zhí)行流要理解協(xié)程首先要跳出“線程”的思維定式。線程是操作系統(tǒng)調(diào)度的基本單位它擁有獨(dú)立的棧和寄存器上下文線程的切換上下文切換是由操作系統(tǒng)內(nèi)核完成的涉及到用戶態(tài)到內(nèi)核態(tài)的轉(zhuǎn)換開銷較大。而協(xié)程是用戶態(tài)下的“輕量級(jí)線程”或者更準(zhǔn)確地說(shuō)是一種“協(xié)作式多任務(wù)”的編程組件。協(xié)程的核心能力就兩點(diǎn)1. 能在任意點(diǎn)掛起Yield2. 能從掛起點(diǎn)恢復(fù)Resume。注意這個(gè)“任意點(diǎn)”通常指的是在協(xié)程函數(shù)的內(nèi)部而不是被操作系統(tǒng)強(qiáng)行中斷。協(xié)程主動(dòng)讓出執(zhí)行權(quán)這就是“協(xié)作式”的含義。一個(gè)協(xié)程看起來(lái)就像一個(gè)可以分段執(zhí)行的函數(shù)。普通函數(shù)一旦開始就會(huì)一直運(yùn)行到return語(yǔ)句結(jié)束然后將控制權(quán)和返回值交還給調(diào)用者。協(xié)程函數(shù)則不同它可以在執(zhí)行到一半時(shí)通過(guò)yield關(guān)鍵字或類似的機(jī)制暫停自己并將一個(gè)值或控制權(quán)返回給調(diào)用者。之后調(diào)用者可以在某個(gè)時(shí)刻命令這個(gè)協(xié)程從上次暫停的地方繼續(xù)執(zhí)行直到下一個(gè)yield或函數(shù)結(jié)束。這個(gè)機(jī)制的關(guān)鍵在于保存和恢復(fù)“執(zhí)行上下文”。對(duì)于線程這個(gè)上下文包括棧指針、指令指針、寄存器值等由操作系統(tǒng)保存。對(duì)于協(xié)程我們需要在用戶態(tài)自己保存。在C#中最直觀的體現(xiàn)就是迭代器IEnumerator。當(dāng)你寫一個(gè)返回IEnumerator的方法并使用yield return時(shí)編譯器會(huì)自動(dòng)為你生成一個(gè)狀態(tài)機(jī)類這個(gè)類內(nèi)部保存了所有局部變量的值以及當(dāng)前執(zhí)行到的位置狀態(tài)。每次調(diào)用MoveNext()狀態(tài)機(jī)就根據(jù)保存的狀態(tài)跳轉(zhuǎn)到對(duì)應(yīng)的代碼塊繼續(xù)執(zhí)行。這就是一個(gè)標(biāo)準(zhǔn)協(xié)程在C#中的官方實(shí)現(xiàn)雛形。所以純C#實(shí)現(xiàn)協(xié)程本質(zhì)上就是要自己模擬這個(gè)“狀態(tài)機(jī)”實(shí)現(xiàn)一個(gè)調(diào)度器來(lái)管理多個(gè)協(xié)程的執(zhí)行、掛起和恢復(fù)而不是依賴編譯器生成的IEnumerator狀態(tài)機(jī)。這讓我們能更自由地定義協(xié)程的“掛起條件”比如等待某個(gè)異步操作完成、等待下一幀、或者等待一個(gè)自定義的信號(hào)。3. 線程 vs. 協(xié)程本質(zhì)區(qū)別與適用場(chǎng)景很多人容易混淆線程和協(xié)程因?yàn)樗鼈兌寄軐?shí)現(xiàn)“同時(shí)”做多件事。但它們的底層原理和適用場(chǎng)景天差地別。我們可以從以下幾個(gè)維度來(lái)對(duì)比3.1 調(diào)度者與開銷線程由操作系統(tǒng)內(nèi)核調(diào)度。線程切換需要陷入內(nèi)核保存和恢復(fù)完整的硬件上下文寄存器、內(nèi)存映射等開銷大通常在微秒級(jí)。協(xié)程由用戶態(tài)的程序通常是協(xié)程調(diào)度器調(diào)度。協(xié)程切換只發(fā)生在用戶態(tài)本質(zhì)上只是修改一些函數(shù)調(diào)用指針和保存少量局部變量狀態(tài)機(jī)狀態(tài)開銷極小納秒級(jí)或更低。你可以在一個(gè)線程內(nèi)輕松運(yùn)行成千上萬(wàn)個(gè)協(xié)程但創(chuàng)建成千上萬(wàn)個(gè)線程則會(huì)耗盡系統(tǒng)資源。3.2 阻塞行為線程當(dāng)一個(gè)線程因?yàn)榈却齀/O如讀寫文件、網(wǎng)絡(luò)請(qǐng)求而阻塞時(shí)這個(gè)線程就被操作系統(tǒng)掛起CPU會(huì)去執(zhí)行其他就緒的線程。線程本身是“搶占式”的可能在任何時(shí)刻被操作系統(tǒng)中斷。協(xié)程協(xié)程是“協(xié)作式”的。如果一個(gè)協(xié)程發(fā)起了一個(gè)阻塞操作比如一個(gè)同步的Socket.Receive那么整個(gè)承載它的線程都會(huì)被阻塞這個(gè)線程上的所有其他協(xié)程也都無(wú)法執(zhí)行。因此協(xié)程必須與非阻塞I/O配合使用。協(xié)程在等待非阻塞I/O時(shí)會(huì)主動(dòng)讓出執(zhí)行權(quán)調(diào)度器可以去執(zhí)行其他就緒的協(xié)程等I/O就緒后再回來(lái)恢復(fù)它。這樣單個(gè)線程就能高效處理海量I/O操作。3.3 內(nèi)存與資源線程每個(gè)線程都有獨(dú)立的、預(yù)分配的?？臻g默認(rèn)在Windows上可能是1MB內(nèi)存占用大。協(xié)程協(xié)程通常只保存必要的狀態(tài)信息局部變量、程序計(jì)數(shù)器?？臻g要么很小要么是共享的復(fù)用線程棧內(nèi)存占用極小。3.4 并行與并發(fā)線程在多核CPU上多個(gè)線程可以被真正地并行執(zhí)行同時(shí)利用多個(gè)核心。協(xié)程協(xié)程本質(zhì)上是并發(fā)而非并行。一個(gè)線程內(nèi)的所有協(xié)程在任何時(shí)刻只有一個(gè)在運(yùn)行。要利用多核需要啟動(dòng)多個(gè)“工作者線程”每個(gè)線程運(yùn)行一個(gè)獨(dú)立的協(xié)程調(diào)度器。很多現(xiàn)代協(xié)程庫(kù)如Go語(yǔ)言的goroutine的運(yùn)行時(shí)系統(tǒng)會(huì)自動(dòng)完成多線程調(diào)度。簡(jiǎn)單總結(jié)一下適用場(chǎng)景使用線程當(dāng)你需要進(jìn)行CPU密集型計(jì)算并且希望利用多核優(yōu)勢(shì)實(shí)現(xiàn)真正并行時(shí)或者當(dāng)你調(diào)用一個(gè)無(wú)法避免的、會(huì)長(zhǎng)時(shí)間阻塞的第三方同步API時(shí)。使用協(xié)程當(dāng)你需要處理高并發(fā)I/O操作如Web服務(wù)器、網(wǎng)絡(luò)爬蟲、游戲服務(wù)器時(shí)協(xié)程配合非阻塞I/O是最高效的模型。它用同步的代碼寫法實(shí)現(xiàn)了異步的高性能。4. 動(dòng)手實(shí)現(xiàn)一個(gè)簡(jiǎn)易的純C#協(xié)程框架理解了原理我們來(lái)實(shí)現(xiàn)一個(gè)最基礎(chǔ)的協(xié)程框架。這個(gè)框架將包含兩個(gè)核心部分Coroutine協(xié)程實(shí)例和CoroutineScheduler協(xié)程調(diào)度器。我們會(huì)用IEnumerator作為協(xié)程體的表示因?yàn)樗腗oveNext和Current天然適合“暫停-恢復(fù)”語(yǔ)義。4.1 定義協(xié)程狀態(tài)與協(xié)程類首先定義一個(gè)協(xié)程可能存在的狀態(tài)。public enum CoroutineStatus { /// summary 已創(chuàng)建尚未開始執(zhí)行 /summary Created, /// summary 正在運(yùn)行 /summary Running, /// summary 執(zhí)行中通過(guò) yield return 暫停 /summary Suspended, /// summary 已正常執(zhí)行完畢 /summary Completed, /// summary 因異常而終止 /summary Faulted }接著定義Coroutine類。它的核心是保存一個(gè)IEnumerator迭代器以及當(dāng)前的狀態(tài)和結(jié)果。public class Coroutine { private IEnumerator _enumerator; public CoroutineStatus Status { get; private set; } public object? Result { get; private set; } public Exception? Exception { get; private set; } // 用于支持 yield return anotherCoroutine即協(xié)程嵌套 private Coroutine? _waitingCoroutine; public Coroutine(IEnumerator enumerator) { _enumerator enumerator ?? throw new ArgumentNullException(nameof(enumerator)); Status CoroutineStatus.Created; } // 核心方法由調(diào)度器調(diào)用推動(dòng)協(xié)程執(zhí)行一步 internal bool MoveNext() { if (Status CoroutineStatus.Completed || Status CoroutineStatus.Faulted) { return false; } Status CoroutineStatus.Running; try { // 如果當(dāng)前正在等待一個(gè)子協(xié)程則先推動(dòng)子協(xié)程 if (_waitingCoroutine ! null) { if (_waitingCoroutine.MoveNext()) { // 子協(xié)程還沒執(zhí)行完本協(xié)程繼續(xù)等待 Status CoroutineStatus.Suspended; return true; } else { // 子協(xié)程執(zhí)行完畢清理并繼續(xù)執(zhí)行本協(xié)程 _waitingCoroutine null; } } // 執(zhí)行迭代器的 MoveNext bool hasNext _enumerator.MoveNext(); if (!hasNext) { // 迭代器執(zhí)行完畢 Status CoroutineStatus.Completed; Result _enumerator.Current; // 最后的 yield return 值或 null return false; } // 處理 yield return 的值 object? yielded _enumerator.Current; if (yielded is Coroutine childCoroutine) { // 如果 yield 了一個(gè)協(xié)程對(duì)象則等待它 _waitingCoroutine childCoroutine; Status CoroutineStatus.Suspended; return true; } else if (yielded is WaitForSeconds wait) { // 模擬Unity的 WaitForSeconds實(shí)際項(xiàng)目中需要更精確的計(jì)時(shí)器 // 這里簡(jiǎn)化為記錄恢復(fù)時(shí)間由調(diào)度器檢查 // 我們用一個(gè)自定義的等待對(duì)象來(lái)示意 _waitingCoroutine wait.AsCoroutine(this); Status CoroutineStatus.Suspended; return true; } else { // 其他類型的 yield return (如 null, 特定指令)都視為暫停一幀 Status CoroutineStatus.Suspended; return true; } } catch (Exception ex) { Status CoroutineStatus.Faulted; Exception ex; return false; } } // 一個(gè)簡(jiǎn)單的等待類用于演示 public class WaitForSeconds { public float Seconds { get; } public WaitForSeconds(float seconds) Seconds seconds; internal Coroutine AsCoroutine(Coroutine parent) { // 這里應(yīng)該返回一個(gè)與計(jì)時(shí)器關(guān)聯(lián)的協(xié)程 // 為簡(jiǎn)化我們返回一個(gè)特殊的、由調(diào)度器處理的協(xié)程 // 實(shí)際實(shí)現(xiàn)需要調(diào)度器維護(hù)一個(gè)延遲恢復(fù)隊(duì)列 return new Coroutine(InternalWait(parent)); } private IEnumerator InternalWait(Coroutine parent) { // 空迭代器實(shí)際等待邏輯在調(diào)度器 yield break; } } }4.2 實(shí)現(xiàn)協(xié)程調(diào)度器調(diào)度器負(fù)責(zé)管理所有協(xié)程的生命周期在一個(gè)循環(huán)中依次推動(dòng)它們。這是一個(gè)最簡(jiǎn)單的單線程調(diào)度器。public class CoroutineScheduler { private readonly ListCoroutine _activeCoroutines new(); private readonly QueueCoroutine _coroutinesToStart new(); // 用于處理延遲恢復(fù)的協(xié)程如 WaitForSeconds private readonly List(Coroutine coroutine, DateTime resumeTime) _delayedCoroutines new(); // 啟動(dòng)一個(gè)協(xié)程 public Coroutine StartCoroutine(IEnumerator routine) { var coroutine new Coroutine(routine); _coroutinesToStart.Enqueue(coroutine); return coroutine; } // 主更新循環(huán)需要由外部如游戲主循環(huán)、定時(shí)器定期調(diào)用 public void Update() { // 1. 添加新協(xié)程 while (_coroutinesToStart.Count 0) { _activeCoroutines.Add(_coroutinesToStart.Dequeue()); } // 2. 處理延遲恢復(fù)的協(xié)程 var now DateTime.UtcNow; for (int i _delayedCoroutines.Count - 1; i 0; i--) { var (coroutine, resumeTime) _delayedCoroutines[i]; if (now resumeTime) { _activeCoroutines.Add(coroutine); _delayedCoroutines.RemoveAt(i); } } // 3. 推動(dòng)所有活躍協(xié)程執(zhí)行一步 for (int i 0; i _activeCoroutines.Count; i) { var coroutine _activeCoroutines[i]; bool keepAlive coroutine.MoveNext(); if (!keepAlive) { // 協(xié)程執(zhí)行完畢或出錯(cuò)從活躍列表移除 _activeCoroutines.RemoveAt(i); i--; // 因?yàn)橐瞥水?dāng)前元素索引回退 // 這里可以觸發(fā)完成回調(diào)等 if (coroutine.Status CoroutineStatus.Faulted) { Console.WriteLine($Coroutine faulted: {coroutine.Exception}); } } // 如果 coroutine.MoveNext() 后狀態(tài)是 Suspended它仍然留在_activeCoroutines中等待下一輪Update } } // 一個(gè)輔助方法用于處理 WaitForSeconds internal void DelayCoroutine(Coroutine coroutine, float seconds) { _delayedCoroutines.Add((coroutine, DateTime.UtcNow.AddSeconds(seconds))); // 注意這里需要將coroutine從_activeCoroutines中移除這部分邏輯在上面的MoveNext中需要配合調(diào)整 // 為了示例清晰這部分細(xì)節(jié)省略實(shí)際需要更精細(xì)的狀態(tài)管理 } }4.3 使用我們自制的協(xié)程現(xiàn)在我們可以像在Unity中一樣使用協(xié)程了。class Program { static IEnumerator MyFirstCoroutine() { Console.WriteLine(Coroutine started at: DateTime.Now.ToString(hh:mm:ss.fff)); // 模擬等待1秒 yield return new Coroutine.WaitForSeconds(1.0f); Console.WriteLine(Coroutine resumed after 1 second at: DateTime.Now.ToString(hh:mm:ss.fff)); for (int i 0; i 3; i) { Console.WriteLine($Loop iteration: {i}); // 每輪循環(huán)暫停一幀一次Update yield return null; } Console.WriteLine(Coroutine finished!); } static void Main(string[] args) { var scheduler new CoroutineScheduler(); scheduler.StartCoroutine(MyFirstCoroutine()); // 模擬游戲主循環(huán)每秒更新60次 var timer new System.Threading.Timer(_ { scheduler.Update(); }, null, 0, 16); // 約16ms一次模擬60FPS Console.ReadLine(); // 防止程序退出 timer.Dispose(); } }這個(gè)簡(jiǎn)易框架演示了協(xié)程最核心的調(diào)度邏輯。但它非?；A(chǔ)缺少錯(cuò)誤處理、取消機(jī)制、依賴注入、性能優(yōu)化如對(duì)象池復(fù)用Coroutine實(shí)例等生產(chǎn)級(jí)功能。像Unity和Godot這樣的游戲引擎它們的協(xié)程系統(tǒng)要復(fù)雜和健壯得多深度集成在引擎的主循環(huán)和生命周期管理中。5. 深入原理C#編譯器為async/await做了什么我們實(shí)現(xiàn)的協(xié)程是基于IEnumerator的。而C#的async/await語(yǔ)法糖其底層也是基于一個(gè)類似的“狀態(tài)機(jī)”模式但它更加強(qiáng)大和高效并且直接得到了語(yǔ)言和運(yùn)行時(shí)的支持。當(dāng)你編寫一個(gè)async方法時(shí)編譯器會(huì)做以下事情生成一個(gè)狀態(tài)機(jī)結(jié)構(gòu)體struct這個(gè)結(jié)構(gòu)體實(shí)現(xiàn)了IAsyncStateMachine接口。它將原方法的所有參數(shù)和局部變量“提升”為這個(gè)結(jié)構(gòu)體的字段。將方法體拆解根據(jù)await表達(dá)式將原方法分割成多個(gè)“續(xù)體”continuation代碼塊。每個(gè)await點(diǎn)就是一個(gè)狀態(tài)遷移點(diǎn)。管理狀態(tài)狀態(tài)機(jī)內(nèi)部有一個(gè)state字段。初始為-1。執(zhí)行到第一個(gè)await時(shí)狀態(tài)變?yōu)?并啟動(dòng)異步操作。異步操作完成后會(huì)回調(diào)狀態(tài)機(jī)的MoveNext方法state變?yōu)?跳轉(zhuǎn)到第一個(gè)await之后的代碼繼續(xù)執(zhí)行依此類推。返回一個(gè) Taskasync方法會(huì)立即返回一個(gè)Task或TaskT。這個(gè)Task代表了整個(gè)異步操作的完成。狀態(tài)機(jī)在最終完成或發(fā)生異常時(shí)會(huì)設(shè)置這個(gè)Task的結(jié)果或異常。與我們手寫協(xié)程的關(guān)鍵區(qū)別調(diào)度器async/await的調(diào)度依賴于SynchronizationContext同步上下文。在UI程序中默認(rèn)的上下文會(huì)將續(xù)體派發(fā)回UI線程執(zhí)行這保證了線程安全。我們的手寫調(diào)度器是單線程、協(xié)作式的。性能編譯器生成的狀態(tài)機(jī)是struct避免了堆分配在Debug模式或某些情況下可能仍會(huì)分配。我們的Coroutine類是class每次創(chuàng)建都有堆分配。.NET Core/5 對(duì)async/await有極致的性能優(yōu)化。生態(tài)集成async/await與整個(gè) .NET 的異步模型Task、TaskCompletionSource、IAsyncDisposable等無(wú)縫集成。我們的手寫協(xié)程需要自己定義所有的等待模式?？梢哉f(shuō)async/await是C#官方提供的、功能完備的、生產(chǎn)級(jí)的“協(xié)程”實(shí)現(xiàn)。我們手動(dòng)實(shí)現(xiàn)協(xié)程更多是出于學(xué)習(xí)目的或是在非常特定的、受限制的環(huán)境下比如沒有async/await支持的舊版.NET Micro Framework的一種解決方案。6. 實(shí)戰(zhàn)避坑手寫協(xié)程框架的常見問題與優(yōu)化如果你真的打算在項(xiàng)目中使用或深入改造自己的協(xié)程框架以下幾個(gè)坑點(diǎn)需要特別注意6.1 堆分配與GC壓力我們的簡(jiǎn)易實(shí)現(xiàn)中每次StartCoroutine都會(huì)new一個(gè)Coroutine對(duì)象每次yield return也可能產(chǎn)生裝箱如果返回的是值類型。在高頻創(chuàng)建和銷毀協(xié)程的場(chǎng)景如游戲中的粒子效果、短時(shí)任務(wù)這會(huì)給垃圾回收器GC帶來(lái)巨大壓力導(dǎo)致卡頓。優(yōu)化方案實(shí)現(xiàn)對(duì)象池。預(yù)創(chuàng)建或復(fù)用Coroutine對(duì)象和內(nèi)部使用的迭代器包裝器。確保協(xié)程執(zhí)行完畢后能將其所有字段重置并放回池中。這需要仔細(xì)管理生命周期避免狀態(tài)污染。6.2 異常處理上面的例子中異常只是被捕獲并存儲(chǔ)在Coroutine對(duì)象里。如何將異常正確地傳播給調(diào)用者是立即拋出還是記錄日志后靜默失敗對(duì)于嵌套協(xié)程協(xié)程A等待協(xié)程BB的異常如何傳遞給A優(yōu)化方案定義統(tǒng)一的異常傳播鏈。當(dāng)子協(xié)程Faulted時(shí)父協(xié)程也應(yīng)該立即進(jìn)入Faulted狀態(tài)并攜帶子協(xié)程的異常?？梢栽贑oroutine.MoveNext()中檢查_waitingCoroutine的狀態(tài)并處理?；蛘咛峁┮粋€(gè)全局的未處理異?；卣{(diào)。6.3 取消操作一個(gè)常見的需求是中途取消一個(gè)正在運(yùn)行的協(xié)程。比如玩家打斷了某個(gè)漫長(zhǎng)的加載過(guò)程。我們的框架沒有提供取消機(jī)制。優(yōu)化方案為Coroutine引入一個(gè)CancellationToken或類似的取消標(biāo)記。在MoveNext()的開始處檢查是否已被取消如果是則立即將狀態(tài)置為Canceled并返回false。調(diào)度器也需要能響應(yīng)取消并從活躍列表中移除被取消的協(xié)程。6.4 精確的時(shí)間控制我們的WaitForSeconds實(shí)現(xiàn)非常粗糙只是用DateTime.UtcNow做比較。在游戲開發(fā)中通常使用基于游戲時(shí)間的增量時(shí)間deltaTime來(lái)驅(qū)動(dòng)并且要處理時(shí)間縮放Time Scale。此外DateTime的精度和性能可能不是最優(yōu)的。優(yōu)化方案使用Stopwatch或游戲引擎提供的高精度計(jì)時(shí)器。調(diào)度器維護(hù)一個(gè)按恢復(fù)時(shí)間排序的優(yōu)先隊(duì)列如SortedList或最小堆而不是線性遍歷列表。在Update中傳入當(dāng)前幀的deltaTime和unscaledDeltaTime。6.5 線程安全問題我們的調(diào)度器假設(shè)在單線程環(huán)境下運(yùn)行。如果在多線程環(huán)境中一個(gè)線程啟動(dòng)協(xié)程另一個(gè)線程調(diào)用Update就會(huì)導(dǎo)致競(jìng)態(tài)條件。優(yōu)化方案對(duì)_activeCoroutines和_coroutinesToStart等共享集合的訪問加鎖如lock語(yǔ)句。但加鎖會(huì)引入性能開銷。更高級(jí)的做法是采用無(wú)鎖隊(duì)列如ConcurrentQueue來(lái)傳遞協(xié)程啟動(dòng)請(qǐng)求并確保Update只在特定線程如主線程調(diào)用。實(shí)現(xiàn)一個(gè)健壯、高性能的協(xié)程框架是一個(gè)復(fù)雜的工程問題。在大多數(shù)情況下直接使用語(yǔ)言和運(yùn)行時(shí)提供的async/await或成熟游戲引擎的內(nèi)置協(xié)程系統(tǒng)是更明智的選擇。手動(dòng)實(shí)現(xiàn)的價(jià)值在于深刻理解其原理從而能更好地使用和調(diào)試這些高級(jí)特性。 C#協(xié)程實(shí)現(xiàn)原理：從狀態(tài)機(jī)到異步編程的底層機(jī)制
1. 從“為什么需要協(xié)程”說(shuō)起如果你寫過(guò)一段時(shí)間C#尤其是在處理UI響應(yīng)、網(wǎng)絡(luò)請(qǐng)求或者游戲邏輯時(shí)大概率會(huì)對(duì)“線程阻塞”這個(gè)詞深惡痛絕。想象一個(gè)場(chǎng)景你的WPF或WinForms界面上有個(gè)按鈕點(diǎn)擊后需要從遠(yuǎn)程服務(wù)器下載一個(gè)文件。如果你用最直接的Thread或者Task.Run去執(zhí)行一個(gè)同步的下載方法UI線程就會(huì)被卡住界面“凍住”用戶會(huì)看到一個(gè)轉(zhuǎn)圈圈的鼠標(biāo)體驗(yàn)極差。這就是典型的“阻塞式”編程帶來(lái)的問題。為了解決這個(gè)問題我們引入了異步編程模型async/await。它讓代碼看起來(lái)是順序執(zhí)行的但底層卻不會(huì)阻塞調(diào)用線程。這背后的大功臣就是“協(xié)程”Coroutine的思想。雖然C#官方文檔里更常提“狀態(tài)機(jī)”和“異步方法”但其核心機(jī)制——能夠暫停和恢復(fù)執(zhí)行流程——正是協(xié)程的典型特征。在Unity游戲開發(fā)中“協(xié)程”更是被直接作為一個(gè)關(guān)鍵字IEnumerator配合yield return來(lái)使用用于實(shí)現(xiàn)跨幀的延時(shí)邏輯比如等待幾秒后執(zhí)行某個(gè)動(dòng)作而不用寫一堆令人頭疼的計(jì)時(shí)器回調(diào)。所以當(dāng)我們?cè)贑#語(yǔ)境下討論“用純C#實(shí)現(xiàn)協(xié)程”時(shí)我們探討的是一種更底層、更可控的流程控制機(jī)制。它不像async/await那樣深度綁定于語(yǔ)言和編譯器也不像Unity的協(xié)程那樣依賴于游戲引擎的生命周期。我們自己實(shí)現(xiàn)的協(xié)程能讓我們更透徹地理解“暫停與恢復(fù)”的本質(zhì)明白協(xié)程與線程的根本區(qū)別從而在那些無(wú)法或不便使用async/await的特定場(chǎng)景比如某些嵌入式環(huán)境、自定義腳本引擎或高性能服務(wù)器核心邏輯中多一種優(yōu)雅的解決方案。2. 協(xié)程的核心可暫停與恢復(fù)的執(zhí)行流要理解協(xié)程首先要跳出“線程”的思維定式。線程是操作系統(tǒng)調(diào)度的基本單位它擁有獨(dú)立的棧和寄存器上下文線程的切換上下文切換是由操作系統(tǒng)內(nèi)核完成的涉及到用戶態(tài)到內(nèi)核態(tài)的轉(zhuǎn)換開銷較大。而協(xié)程是用戶態(tài)下的“輕量級(jí)線程”或者更準(zhǔn)確地說(shuō)是一種“協(xié)作式多任務(wù)”的編程組件。協(xié)程的核心能力就兩點(diǎn)1. 能在任意點(diǎn)掛起Yield2. 能從掛起點(diǎn)恢復(fù)Resume。注意這個(gè)“任意點(diǎn)”通常指的是在協(xié)程函數(shù)的內(nèi)部而不是被操作系統(tǒng)強(qiáng)行中斷。協(xié)程主動(dòng)讓出執(zhí)行權(quán)這就是“協(xié)作式”的含義。一個(gè)協(xié)程看起來(lái)就像一個(gè)可以分段執(zhí)行的函數(shù)。普通函數(shù)一旦開始就會(huì)一直運(yùn)行到return語(yǔ)句結(jié)束然后將控制權(quán)和返回值交還給調(diào)用者。協(xié)程函數(shù)則不同它可以在執(zhí)行到一半時(shí)通過(guò)yield關(guān)鍵字或類似的機(jī)制暫停自己并將一個(gè)值或控制權(quán)返回給調(diào)用者。之后調(diào)用者可以在某個(gè)時(shí)刻命令這個(gè)協(xié)程從上次暫停的地方繼續(xù)執(zhí)行直到下一個(gè)yield或函數(shù)結(jié)束。這個(gè)機(jī)制的關(guān)鍵在于保存和恢復(fù)“執(zhí)行上下文”。對(duì)于線程這個(gè)上下文包括棧指針、指令指針、寄存器值等由操作系統(tǒng)保存。對(duì)于協(xié)程我們需要在用戶態(tài)自己保存。在C#中最直觀的體現(xiàn)就是迭代器IEnumerator。當(dāng)你寫一個(gè)返回IEnumerator的方法并使用yield return時(shí)編譯器會(huì)自動(dòng)為你生成一個(gè)狀態(tài)機(jī)類這個(gè)類內(nèi)部保存了所有局部變量的值以及當(dāng)前執(zhí)行到的位置狀態(tài)。每次調(diào)用MoveNext()狀態(tài)機(jī)就根據(jù)保存的狀態(tài)跳轉(zhuǎn)到對(duì)應(yīng)的代碼塊繼續(xù)執(zhí)行。這就是一個(gè)標(biāo)準(zhǔn)協(xié)程在C#中的官方實(shí)現(xiàn)雛形。所以純C#實(shí)現(xiàn)協(xié)程本質(zhì)上就是要自己模擬這個(gè)“狀態(tài)機(jī)”實(shí)現(xiàn)一個(gè)調(diào)度器來(lái)管理多個(gè)協(xié)程的執(zhí)行、掛起和恢復(fù)而不是依賴編譯器生成的IEnumerator狀態(tài)機(jī)。這讓我們能更自由地定義協(xié)程的“掛起條件”比如等待某個(gè)異步操作完成、等待下一幀、或者等待一個(gè)自定義的信號(hào)。3. 線程 vs. 協(xié)程本質(zhì)區(qū)別與適用場(chǎng)景很多人容易混淆線程和協(xié)程因?yàn)樗鼈兌寄軐?shí)現(xiàn)“同時(shí)”做多件事。但它們的底層原理和適用場(chǎng)景天差地別。我們可以從以下幾個(gè)維度來(lái)對(duì)比3.1 調(diào)度者與開銷線程由操作系統(tǒng)內(nèi)核調(diào)度。線程切換需要陷入內(nèi)核保存和恢復(fù)完整的硬件上下文寄存器、內(nèi)存映射等開銷大通常在微秒級(jí)。協(xié)程由用戶態(tài)的程序通常是協(xié)程調(diào)度器調(diào)度。協(xié)程切換只發(fā)生在用戶態(tài)本質(zhì)上只是修改一些函數(shù)調(diào)用指針和保存少量局部變量狀態(tài)機(jī)狀態(tài)開銷極小納秒級(jí)或更低。你可以在一個(gè)線程內(nèi)輕松運(yùn)行成千上萬(wàn)個(gè)協(xié)程但創(chuàng)建成千上萬(wàn)個(gè)線程則會(huì)耗盡系統(tǒng)資源。3.2 阻塞行為線程當(dāng)一個(gè)線程因?yàn)榈却齀/O如讀寫文件、網(wǎng)絡(luò)請(qǐng)求而阻塞時(shí)這個(gè)線程就被操作系統(tǒng)掛起CPU會(huì)去執(zhí)行其他就緒的線程。線程本身是“搶占式”的可能在任何時(shí)刻被操作系統(tǒng)中斷。協(xié)程協(xié)程是“協(xié)作式”的。如果一個(gè)協(xié)程發(fā)起了一個(gè)阻塞操作比如一個(gè)同步的Socket.Receive那么整個(gè)承載它的線程都會(huì)被阻塞這個(gè)線程上的所有其他協(xié)程也都無(wú)法執(zhí)行。因此協(xié)程必須與非阻塞I/O配合使用。協(xié)程在等待非阻塞I/O時(shí)會(huì)主動(dòng)讓出執(zhí)行權(quán)調(diào)度器可以去執(zhí)行其他就緒的協(xié)程等I/O就緒后再回來(lái)恢復(fù)它。這樣單個(gè)線程就能高效處理海量I/O操作。3.3 內(nèi)存與資源線程每個(gè)線程都有獨(dú)立的、預(yù)分配的?？臻g默認(rèn)在Windows上可能是1MB內(nèi)存占用大。協(xié)程協(xié)程通常只保存必要的狀態(tài)信息局部變量、程序計(jì)數(shù)器?？臻g要么很小要么是共享的復(fù)用線程棧內(nèi)存占用極小。3.4 并行與并發(fā)線程在多核CPU上多個(gè)線程可以被真正地并行執(zhí)行同時(shí)利用多個(gè)核心。協(xié)程協(xié)程本質(zhì)上是并發(fā)而非并行。一個(gè)線程內(nèi)的所有協(xié)程在任何時(shí)刻只有一個(gè)在運(yùn)行。要利用多核需要啟動(dòng)多個(gè)“工作者線程”每個(gè)線程運(yùn)行一個(gè)獨(dú)立的協(xié)程調(diào)度器。很多現(xiàn)代協(xié)程庫(kù)如Go語(yǔ)言的goroutine的運(yùn)行時(shí)系統(tǒng)會(huì)自動(dòng)完成多線程調(diào)度。簡(jiǎn)單總結(jié)一下適用場(chǎng)景使用線程當(dāng)你需要進(jìn)行CPU密集型計(jì)算并且希望利用多核優(yōu)勢(shì)實(shí)現(xiàn)真正并行時(shí)或者當(dāng)你調(diào)用一個(gè)無(wú)法避免的、會(huì)長(zhǎng)時(shí)間阻塞的第三方同步API時(shí)。使用協(xié)程當(dāng)你需要處理高并發(fā)I/O操作如Web服務(wù)器、網(wǎng)絡(luò)爬蟲、游戲服務(wù)器時(shí)協(xié)程配合非阻塞I/O是最高效的模型。它用同步的代碼寫法實(shí)現(xiàn)了異步的高性能。4. 動(dòng)手實(shí)現(xiàn)一個(gè)簡(jiǎn)易的純C#協(xié)程框架理解了原理我們來(lái)實(shí)現(xiàn)一個(gè)最基礎(chǔ)的協(xié)程框架。這個(gè)框架將包含兩個(gè)核心部分Coroutine協(xié)程實(shí)例和CoroutineScheduler協(xié)程調(diào)度器。我們會(huì)用IEnumerator作為協(xié)程體的表示因?yàn)樗腗oveNext和Current天然適合“暫停-恢復(fù)”語(yǔ)義。4.1 定義協(xié)程狀態(tài)與協(xié)程類首先定義一個(gè)協(xié)程可能存在的狀態(tài)。public enum CoroutineStatus { /// summary 已創(chuàng)建尚未開始執(zhí)行 /summary Created, /// summary 正在運(yùn)行 /summary Running, /// summary 執(zhí)行中通過(guò) yield return 暫停 /summary Suspended, /// summary 已正常執(zhí)行完畢 /summary Completed, /// summary 因異常而終止 /summary Faulted }接著定義Coroutine類。它的核心是保存一個(gè)IEnumerator迭代器以及當(dāng)前的狀態(tài)和結(jié)果。public class Coroutine { private IEnumerator _enumerator; public CoroutineStatus Status { get; private set; } public object? Result { get; private set; } public Exception? Exception { get; private set; } // 用于支持 yield return anotherCoroutine即協(xié)程嵌套 private Coroutine? _waitingCoroutine; public Coroutine(IEnumerator enumerator) { _enumerator enumerator ?? throw new ArgumentNullException(nameof(enumerator)); Status CoroutineStatus.Created; } // 核心方法由調(diào)度器調(diào)用推動(dòng)協(xié)程執(zhí)行一步 internal bool MoveNext() { if (Status CoroutineStatus.Completed || Status CoroutineStatus.Faulted) { return false; } Status CoroutineStatus.Running; try { // 如果當(dāng)前正在等待一個(gè)子協(xié)程則先推動(dòng)子協(xié)程 if (_waitingCoroutine ! null) { if (_waitingCoroutine.MoveNext()) { // 子協(xié)程還沒執(zhí)行完本協(xié)程繼續(xù)等待 Status CoroutineStatus.Suspended; return true; } else { // 子協(xié)程執(zhí)行完畢清理并繼續(xù)執(zhí)行本協(xié)程 _waitingCoroutine null; } } // 執(zhí)行迭代器的 MoveNext bool hasNext _enumerator.MoveNext(); if (!hasNext) { // 迭代器執(zhí)行完畢 Status CoroutineStatus.Completed; Result _enumerator.Current; // 最后的 yield return 值或 null return false; } // 處理 yield return 的值 object? yielded _enumerator.Current; if (yielded is Coroutine childCoroutine) { // 如果 yield 了一個(gè)協(xié)程對(duì)象則等待它 _waitingCoroutine childCoroutine; Status CoroutineStatus.Suspended; return true; } else if (yielded is WaitForSeconds wait) { // 模擬Unity的 WaitForSeconds實(shí)際項(xiàng)目中需要更精確的計(jì)時(shí)器 // 這里簡(jiǎn)化為記錄恢復(fù)時(shí)間由調(diào)度器檢查 // 我們用一個(gè)自定義的等待對(duì)象來(lái)示意 _waitingCoroutine wait.AsCoroutine(this); Status CoroutineStatus.Suspended; return true; } else { // 其他類型的 yield return (如 null, 特定指令)都視為暫停一幀 Status CoroutineStatus.Suspended; return true; } } catch (Exception ex) { Status CoroutineStatus.Faulted; Exception ex; return false; } } // 一個(gè)簡(jiǎn)單的等待類用于演示 public class WaitForSeconds { public float Seconds { get; } public WaitForSeconds(float seconds) Seconds seconds; internal Coroutine AsCoroutine(Coroutine parent) { // 這里應(yīng)該返回一個(gè)與計(jì)時(shí)器關(guān)聯(lián)的協(xié)程 // 為簡(jiǎn)化我們返回一個(gè)特殊的、由調(diào)度器處理的協(xié)程 // 實(shí)際實(shí)現(xiàn)需要調(diào)度器維護(hù)一個(gè)延遲恢復(fù)隊(duì)列 return new Coroutine(InternalWait(parent)); } private IEnumerator InternalWait(Coroutine parent) { // 空迭代器實(shí)際等待邏輯在調(diào)度器 yield break; } } }4.2 實(shí)現(xiàn)協(xié)程調(diào)度器調(diào)度器負(fù)責(zé)管理所有協(xié)程的生命周期在一個(gè)循環(huán)中依次推動(dòng)它們。這是一個(gè)最簡(jiǎn)單的單線程調(diào)度器。public class CoroutineScheduler { private readonly ListCoroutine _activeCoroutines new(); private readonly QueueCoroutine _coroutinesToStart new(); // 用于處理延遲恢復(fù)的協(xié)程如 WaitForSeconds private readonly List(Coroutine coroutine, DateTime resumeTime) _delayedCoroutines new(); // 啟動(dòng)一個(gè)協(xié)程 public Coroutine StartCoroutine(IEnumerator routine) { var coroutine new Coroutine(routine); _coroutinesToStart.Enqueue(coroutine); return coroutine; } // 主更新循環(huán)需要由外部如游戲主循環(huán)、定時(shí)器定期調(diào)用 public void Update() { // 1. 添加新協(xié)程 while (_coroutinesToStart.Count 0) { _activeCoroutines.Add(_coroutinesToStart.Dequeue()); } // 2. 處理延遲恢復(fù)的協(xié)程 var now DateTime.UtcNow; for (int i _delayedCoroutines.Count - 1; i 0; i--) { var (coroutine, resumeTime) _delayedCoroutines[i]; if (now resumeTime) { _activeCoroutines.Add(coroutine); _delayedCoroutines.RemoveAt(i); } } // 3. 推動(dòng)所有活躍協(xié)程執(zhí)行一步 for (int i 0; i _activeCoroutines.Count; i) { var coroutine _activeCoroutines[i]; bool keepAlive coroutine.MoveNext(); if (!keepAlive) { // 協(xié)程執(zhí)行完畢或出錯(cuò)從活躍列表移除 _activeCoroutines.RemoveAt(i); i--; // 因?yàn)橐瞥水?dāng)前元素索引回退 // 這里可以觸發(fā)完成回調(diào)等 if (coroutine.Status CoroutineStatus.Faulted) { Console.WriteLine($Coroutine faulted: {coroutine.Exception}); } } // 如果 coroutine.MoveNext() 后狀態(tài)是 Suspended它仍然留在_activeCoroutines中等待下一輪Update } } // 一個(gè)輔助方法用于處理 WaitForSeconds internal void DelayCoroutine(Coroutine coroutine, float seconds) { _delayedCoroutines.Add((coroutine, DateTime.UtcNow.AddSeconds(seconds))); // 注意這里需要將coroutine從_activeCoroutines中移除這部分邏輯在上面的MoveNext中需要配合調(diào)整 // 為了示例清晰這部分細(xì)節(jié)省略實(shí)際需要更精細(xì)的狀態(tài)管理 } }4.3 使用我們自制的協(xié)程現(xiàn)在我們可以像在Unity中一樣使用協(xié)程了。class Program { static IEnumerator MyFirstCoroutine() { Console.WriteLine(Coroutine started at: DateTime.Now.ToString(hh:mm:ss.fff)); // 模擬等待1秒 yield return new Coroutine.WaitForSeconds(1.0f); Console.WriteLine(Coroutine resumed after 1 second at: DateTime.Now.ToString(hh:mm:ss.fff)); for (int i 0; i 3; i) { Console.WriteLine($Loop iteration: {i}); // 每輪循環(huán)暫停一幀一次Update yield return null; } Console.WriteLine(Coroutine finished!); } static void Main(string[] args) { var scheduler new CoroutineScheduler(); scheduler.StartCoroutine(MyFirstCoroutine()); // 模擬游戲主循環(huán)每秒更新60次 var timer new System.Threading.Timer(_ { scheduler.Update(); }, null, 0, 16); // 約16ms一次模擬60FPS Console.ReadLine(); // 防止程序退出 timer.Dispose(); } }這個(gè)簡(jiǎn)易框架演示了協(xié)程最核心的調(diào)度邏輯。但它非?；A(chǔ)缺少錯(cuò)誤處理、取消機(jī)制、依賴注入、性能優(yōu)化如對(duì)象池復(fù)用Coroutine實(shí)例等生產(chǎn)級(jí)功能。像Unity和Godot這樣的游戲引擎它們的協(xié)程系統(tǒng)要復(fù)雜和健壯得多深度集成在引擎的主循環(huán)和生命周期管理中。5. 深入原理C#編譯器為async/await做了什么我們實(shí)現(xiàn)的協(xié)程是基于IEnumerator的。而C#的async/await語(yǔ)法糖其底層也是基于一個(gè)類似的“狀態(tài)機(jī)”模式但它更加強(qiáng)大和高效并且直接得到了語(yǔ)言和運(yùn)行時(shí)的支持。當(dāng)你編寫一個(gè)async方法時(shí)編譯器會(huì)做以下事情生成一個(gè)狀態(tài)機(jī)結(jié)構(gòu)體struct這個(gè)結(jié)構(gòu)體實(shí)現(xiàn)了IAsyncStateMachine接口。它將原方法的所有參數(shù)和局部變量“提升”為這個(gè)結(jié)構(gòu)體的字段。將方法體拆解根據(jù)await表達(dá)式將原方法分割成多個(gè)“續(xù)體”continuation代碼塊。每個(gè)await點(diǎn)就是一個(gè)狀態(tài)遷移點(diǎn)。管理狀態(tài)狀態(tài)機(jī)內(nèi)部有一個(gè)state字段。初始為-1。執(zhí)行到第一個(gè)await時(shí)狀態(tài)變?yōu)?并啟動(dòng)異步操作。異步操作完成后會(huì)回調(diào)狀態(tài)機(jī)的MoveNext方法state變?yōu)?跳轉(zhuǎn)到第一個(gè)await之后的代碼繼續(xù)執(zhí)行依此類推。返回一個(gè) Taskasync方法會(huì)立即返回一個(gè)Task或TaskT。這個(gè)Task代表了整個(gè)異步操作的完成。狀態(tài)機(jī)在最終完成或發(fā)生異常時(shí)會(huì)設(shè)置這個(gè)Task的結(jié)果或異常。與我們手寫協(xié)程的關(guān)鍵區(qū)別調(diào)度器async/await的調(diào)度依賴于SynchronizationContext同步上下文。在UI程序中默認(rèn)的上下文會(huì)將續(xù)體派發(fā)回UI線程執(zhí)行這保證了線程安全。我們的手寫調(diào)度器是單線程、協(xié)作式的。性能編譯器生成的狀態(tài)機(jī)是struct避免了堆分配在Debug模式或某些情況下可能仍會(huì)分配。我們的Coroutine類是class每次創(chuàng)建都有堆分配。.NET Core/5 對(duì)async/await有極致的性能優(yōu)化。生態(tài)集成async/await與整個(gè) .NET 的異步模型Task、TaskCompletionSource、IAsyncDisposable等無(wú)縫集成。我們的手寫協(xié)程需要自己定義所有的等待模式?？梢哉f(shuō)async/await是C#官方提供的、功能完備的、生產(chǎn)級(jí)的“協(xié)程”實(shí)現(xiàn)。我們手動(dòng)實(shí)現(xiàn)協(xié)程更多是出于學(xué)習(xí)目的或是在非常特定的、受限制的環(huán)境下比如沒有async/await支持的舊版.NET Micro Framework的一種解決方案。6. 實(shí)戰(zhàn)避坑手寫協(xié)程框架的常見問題與優(yōu)化如果你真的打算在項(xiàng)目中使用或深入改造自己的協(xié)程框架以下幾個(gè)坑點(diǎn)需要特別注意6.1 堆分配與GC壓力我們的簡(jiǎn)易實(shí)現(xiàn)中每次StartCoroutine都會(huì)new一個(gè)Coroutine對(duì)象每次yield return也可能產(chǎn)生裝箱如果返回的是值類型。在高頻創(chuàng)建和銷毀協(xié)程的場(chǎng)景如游戲中的粒子效果、短時(shí)任務(wù)這會(huì)給垃圾回收器GC帶來(lái)巨大壓力導(dǎo)致卡頓。優(yōu)化方案實(shí)現(xiàn)對(duì)象池。預(yù)創(chuàng)建或復(fù)用Coroutine對(duì)象和內(nèi)部使用的迭代器包裝器。確保協(xié)程執(zhí)行完畢后能將其所有字段重置并放回池中。這需要仔細(xì)管理生命周期避免狀態(tài)污染。6.2 異常處理上面的例子中異常只是被捕獲并存儲(chǔ)在Coroutine對(duì)象里。如何將異常正確地傳播給調(diào)用者是立即拋出還是記錄日志后靜默失敗對(duì)于嵌套協(xié)程協(xié)程A等待協(xié)程BB的異常如何傳遞給A優(yōu)化方案定義統(tǒng)一的異常傳播鏈。當(dāng)子協(xié)程Faulted時(shí)父協(xié)程也應(yīng)該立即進(jìn)入Faulted狀態(tài)并攜帶子協(xié)程的異常?？梢栽贑oroutine.MoveNext()中檢查_waitingCoroutine的狀態(tài)并處理?；蛘咛峁┮粋€(gè)全局的未處理異?；卣{(diào)。6.3 取消操作一個(gè)常見的需求是中途取消一個(gè)正在運(yùn)行的協(xié)程。比如玩家打斷了某個(gè)漫長(zhǎng)的加載過(guò)程。我們的框架沒有提供取消機(jī)制。優(yōu)化方案為Coroutine引入一個(gè)CancellationToken或類似的取消標(biāo)記。在MoveNext()的開始處檢查是否已被取消如果是則立即將狀態(tài)置為Canceled并返回false。調(diào)度器也需要能響應(yīng)取消并從活躍列表中移除被取消的協(xié)程。6.4 精確的時(shí)間控制我們的WaitForSeconds實(shí)現(xiàn)非常粗糙只是用DateTime.UtcNow做比較。在游戲開發(fā)中通常使用基于游戲時(shí)間的增量時(shí)間deltaTime來(lái)驅(qū)動(dòng)并且要處理時(shí)間縮放Time Scale。此外DateTime的精度和性能可能不是最優(yōu)的。優(yōu)化方案使用Stopwatch或游戲引擎提供的高精度計(jì)時(shí)器。調(diào)度器維護(hù)一個(gè)按恢復(fù)時(shí)間排序的優(yōu)先隊(duì)列如SortedList或最小堆而不是線性遍歷列表。在Update中傳入當(dāng)前幀的deltaTime和unscaledDeltaTime。6.5 線程安全問題我們的調(diào)度器假設(shè)在單線程環(huán)境下運(yùn)行。如果在多線程環(huán)境中一個(gè)線程啟動(dòng)協(xié)程另一個(gè)線程調(diào)用Update就會(huì)導(dǎo)致競(jìng)態(tài)條件。優(yōu)化方案對(duì)_activeCoroutines和_coroutinesToStart等共享集合的訪問加鎖如lock語(yǔ)句。但加鎖會(huì)引入性能開銷。更高級(jí)的做法是采用無(wú)鎖隊(duì)列如ConcurrentQueue來(lái)傳遞協(xié)程啟動(dòng)請(qǐng)求并確保Update只在特定線程如主線程調(diào)用。實(shí)現(xiàn)一個(gè)健壯、高性能的協(xié)程框架是一個(gè)復(fù)雜的工程問題。在大多數(shù)情況下直接使用語(yǔ)言和運(yùn)行時(shí)提供的async/await或成熟游戲引擎的內(nèi)置協(xié)程系統(tǒng)是更明智的選擇。手動(dòng)實(shí)現(xiàn)的價(jià)值在于深刻理解其原理從而能更好地使用和調(diào)試這些高級(jí)特性。