通過包裝非托管纖程_api_為_net_實(shí)現(xiàn)代碼協(xié)同(編輯修改稿)
2024-09-19 18:32 本頁面
【文章內(nèi)容簡(jiǎn)介】 0), state(FiberCreated) { void *objptr = (void*) GCHandle::op_Explicit(GCHandle::Alloc(this))。 fiber = CreateFiber(0, unmanaged_fiberproc, objptr)。}Fiber 對(duì)象的構(gòu)造函數(shù)創(chuàng)建一個(gè)新纖程，該纖程在被調(diào)度后將立即開始執(zhí)行 unmanaged_fiberproc 函數(shù)。在創(chuàng)建纖程時(shí)，Windows 允許您向纖程過程傳遞上下文信息。當(dāng)纖程被調(diào)度時(shí)，它可以訪問傳遞給它的信息。構(gòu)造函數(shù)將指向 Fiber 對(duì)象的指針傳遞給非托管函數(shù)。由于不可能將托管指針直接傳遞給非托管代碼，因此我使用 System::Runtime::InteropServices 命名空間中的 GCHandle 類獲得指向托管 Fiber 對(duì)象的非托管指針（參見圖 2）。 現(xiàn)在討論棘手的部分。一旦我切換到該纖程并且非托管代碼開始執(zhí)行，我就需要向運(yùn)行庫發(fā)出有關(guān)剛剛創(chuàng)建的纖程的警告。未公開的函數(shù) ICorRuntimeHost::CreateLogicalThread 告訴運(yùn)行庫設(shè)置托管線程（包括它自己的異常列表以及該纖程的 CLR 內(nèi)部的其他數(shù)據(jù)）。這意味著對(duì)于每個(gè)纖程，都有一個(gè)相對(duì)應(yīng)的托管線程。由于可以在同一 OS 線程上調(diào)度很多個(gè)纖程，因此這意味著多個(gè)托管線程可以在同一 OS 線程上運(yùn)行。而且，因?yàn)樯院罂梢栽诹硗庖粋€(gè) OS 線程上調(diào)度纖程，所以托管線程可以在不同的 OS 線程之間移動(dòng)?？梢酝ㄟ^本文的代碼下載獲得的示例應(yīng)用程序 演示了這一概念（參見位于本文頂部的鏈接）。然后，非托管函數(shù)調(diào)用托管 fibermain 函數(shù)，并向其傳遞指向托管 Fiber 對(duì)象的指針。一旦 fibermain 返回，CLR 就不相干了?？刂品祷氐椒峭泄艽a，我在此刪除了我為該纖程創(chuàng)建的托管線程狀態(tài)。然后，我切換回最后一次調(diào)度該纖程的纖程。托管 fibermain 函數(shù)只是獲得 Fiber 對(duì)象并調(diào)用它的私有 main 方法： void* main() { state = FiberRunning。 try { Run()。 } catch(System::Object *x) { System::Console::ErrorWriteLine( S\: main Caught {0}, x)。 } state = FiberStopped。 retval = 0。 return previousfiber。}Main 方法將纖程的狀態(tài)設(shè)置為“正在運(yùn)行”，并且設(shè)置一個(gè)異常處理程序以捕獲任何異常。與 C 中不同的是，托管 C++ 使我可以捕獲不是派生自 Exception 類的異常。當(dāng)我實(shí)現(xiàn) Dispose 方法時(shí)，我將很好地利用這一功能。Run 可以正常返回或產(chǎn)生異常。在任一情況下，fibermain 都將獲得控制，將狀態(tài)設(shè)置為“停止”，并且返回最后一次調(diào)度該纖程的纖程。 在托管代碼中，用戶可以使用 Resume 和 Yield 方法在纖程之間切換。正如前面說明的那樣，在纖程之間切換之前，需要通知 CLR。在進(jìn)行 OS 級(jí)別 SwitchToFiber 之前，您必須告訴 CLR 保存當(dāng)前正在運(yùn)行的纖程的托管線程狀態(tài)。正如您可以看到的那樣，非托管函數(shù) CorSwitchToFiber 完成這一工作： pragma unmanagedvoid CorSwitchToFiber(void *fiber) { DWORD *cookie。 corhostSwitchOutLogicalThreadState(amp。cookie)。 SwitchToFiber(fiber)。 corhostSwitchInLogicalThreadState(cookie)。}CorSwitchToFiber 使用 ICorRuntimeHost::SwitchOutLogicalThreadState 方法在一個(gè)局部變量中保存線程狀態(tài)，該方法存在于共享源 CLI 中（請(qǐng)記住，每個(gè)纖程都具有它自己的堆棧）。在保存狀態(tài)之后，它將完成 OS 級(jí)別纖程切換。稍后，當(dāng)切換到該纖程中時(shí)，將通過 Yield 或 Resume 還原 CLR 線程狀態(tài)： System::Object* Resume() { if(!fiber || state == FiberStopped) return 0。 previousfiber = GetCurrentFiber()。 CorSwitchToFiber(fiber)。 return retval。}Resume 方法首先檢查該纖程是否已經(jīng)停止；如果尚未停止，則將 previousfiber 字段設(shè)置為當(dāng)前正在運(yùn)行的纖程并且進(jìn)行 CorSwitchToFiber。 Yield 可以從 Run（它由代碼協(xié)同實(shí)現(xiàn)）中或者從 Run 調(diào)用的方法中調(diào)用。Yield 切換到調(diào)度當(dāng)前纖程的纖程，向其傳遞要輸出的值，如以下代碼中所示： __gc private struct StopFiber {}。
環(huán)評(píng)公示相關(guān)推薦
鄂ICP備17016276號(hào)-1