Java 協程實戰：基於 Scala Actor 與 Kilim 實現高並發非阻塞編程模型

傳統 Java 多線程模型下，高並發意味著大量線程創建與切換開銷。協程（Coroutine）讓任務主動釋放線程（如 IO 等待時），由用戶態調度器切換任務，大幅降低內核切換成本，理論上能支撐百萬級並發。Java 語言層面暫未原生支持（Java 7 曾有實驗版），當前主流方案：Scala Actor、Kilim 框架。

背景知識：從 OS 調度到協程模型

• OS 多任務：搶佔式（時間片輪轉）vs 協作式（主動讓出）
• 傳統高並發：一請求一線程，IO 等待阻塞線程，線程數 = 並發數，切換開銷大
• 協程模型：任務非獨佔線程，IO 等待時主動讓出線程，用戶態調度，單機可跑數十萬協程
• Actor Model：任務 = Actor，通過消息傳遞交互（無共享狀態），支持 Continuations（阻塞時釋放線程，恢復時繼續執行）

Scala Actor 核心機制

Actor 基礎

輕量級 Java Thread，繼承 Actor 實現 act()，start() 啟動。異於 Thread，可接收外部消息處理。

消息發送：異步 vs Future

actor ! Msg          // 異步，發即返
actor !! Msg         // Future，阻塞等待結果
val ft = actor !! Msg
val result = ft()              // 無限等待
val results = awaitAll(500, ft1, ft2) // 限時等待多個
val results = awaitEither(ft1, ft2)   // 等待任意一個

接收端用 reply(result) 返回 Future 結果。

消息接收：receive vs react

receive { case Msg(args) => handle(args) }  // 阻塞 Java 線程
react   { case Msg(args) => handle(args) }  // 僅阻塞 Actor，釋放 Java 線程（推薦）

react 不支持返回值，但能充分發揮協程優勢。均支持限時版 receiveWithin/reactWithin，超時匹配 case TIMEOUT。

Scala Actor 並發處理器示例

class Processor extends Actor {
  def act() {
    loop {
      react {
        case command: String => doHandle(command)
      }
    }
  }
  def doHandle(command: String) { /* 業務邏輯 */ }
}

Kilim 框架簡介

基於字節碼增強（織入）實現協程，提供 Task 基類，通過 pause() 釋放線程。需專用編譯器 kilim.tools.Weaver 處理類文件。性能極佳，但部署較繁瑣。

選型建議

• 新項目、團隊接受 Scala：首選 Scala Actor（現 Akka 更成熟）
• 純 Java 環境、極致性能：Kilim
• Java 19+：原生虛擬線程（Virtual Threads / Project Loom）為終極方案