您现在的位置：程式碼之家 >> 編程語言 > >> .NET 網頁程式設計 >> 關於.NET

並發與協調運行時（CCR）深度解析：無鎖異步編程新范式

編輯：關於.NET

CCR 核心價值

CCR（Concurrency and Coordination Runtime）是 .NET 平台上的異步消息傳遞庫，提供輕量級、類型安全的通道與面向 Action 的組件連接方式。其核心優勢：

極大簡化線程、鎖、互斥體等同步元素的直接操作。
單線程應用提升響應與 CPU 利用率；多線程應用簡化代碼同時保持/提升吞吐量。
提供失敗隔離模型（Causality），異步錯誤可在統一上下文處理。
高效利用現有/未來計算資源，支持 CLR 線程池或自帶 Dispatcher。
簡化異步 I/O 編程，釋放線程處理其他任務。

基礎類型體系

Task：任意可執行代碼片段。
TaskQueue (DispatcherQueue)：待執行任務列表，線程池從中取任務執行。
Port：進程內組件連接的消息隊列（泛型支持類型安全）。
Arbiters：連接 Port 與 Task 的基礎元素，定義約束，消息到達時決定創建什麼任務、用哪個隊列。內置多種仲裁器且可組合。

入門示例：從直接入隊到端口激活

1. 直接入隊任務

taskQueue.Enqueue(Arbiter.FromHandler(() => Console.WriteLine("Hello, world.")));

2. 端口發布消息觸發任務

var port = new Port();
Arbiter.Activate(taskQueue, port.Receive(Console.WriteLine));
port.Post("Hello (again), world");

port.Receive 創建一次性接收器；Arbiter.Activate 綁定任務隊列。關鍵點：仲裁器永不阻塞線程，無消息時線程釋放處理其他任務。

3. 持久接收器處理多條消息

Arbiter.Activate(taskQueue, Arbiter.Receive(true, port, Console.WriteLine));

第一個參數 true 表示持久化，處理完不銷毀。多條消息並發處理時順序不保證。

進階控制：迭代任務與仲裁器組合

迭代任務：順序處理消息

static IEnumerator ProcessMessages(Port port) {
 while (true) yield return port.Receive(Console.WriteLine);
 }
Arbiter.Activate(taskQueue, new IterativeTask(port, ProcessMessages));

利用 C# 迭代器（yield return）實現非阻塞的順序邏輯，代碼風格接近同步調用。

Choice（選擇器）：多端口非確定性選擇

yield return portSet.Choice(msg => Console.WriteLine(msg), signal => fDone = true);

Join（級聯）：多條件同時滿足觸發

Arbiter.JoinedReceive(false, port1, port2, (x, y) => Console.WriteLine(x + y));

適用於資源有限場景：請求端口 + 資源端口，僅當資源可用時處理請求。

Interleave（交織）：讀寫鎖語義的異步實現

ConcurrentReceiverGroup：讀任務並發。
ExclusiveReceiverGroup：寫任務獨占，優先級高。
TeardownReceiverGroup：關閉時執行清理。

異步 I/O 與因果關係（Causality）錯誤處理

異步文件複製示例

static IEnumerator Copy(FileStream source, FileStream target) {
 var buffer = new byte[128*1024]; var port = new Port();
 do {
   source.BeginRead(buffer, 0, buffer.Length, port.Post, null);
   yield return Arbiter.Receive(false, port, iar => bytesRead = source.EndRead(iar));
   target.BeginWrite(buffer, 0, bytesRead, port.Post, null);
   yield return Arbiter.Receive(false, port, iar => target.EndWrite(iar));
 } while (bytesRead > 0);
 }

Causality：統一異常處理

var exceptionPort = new Port();
Arbiter.Activate(taskQueue, exceptionPort.Receive(e => { Console.ForegroundColor=ConsoleColor.Red; Console.WriteLine("Caught "+e); Console.ResetColor(); }));
Dispatcher.AddCausality(new Causality("Example", exceptionPort));

捕獲任意任務執行過程中的異常，避免顯式 try/catch 導致的代碼膨脹與線程親和性問題。