打造專屬 Java 超級計算機：偽遠程線程模型實戰

背景與動機

並行集群正重塑超級計算版圖，但主流方案基於 C/C++ 的 MPI/PVM，並行編程門檻極高。本文介紹一種基於 Java 線程與 RMI 的偽遠程線程模型，讓每位 Java 程序員都能構建自己的超級計算機。

系統架構

超級計算機定義：由 8+ 節點組成、作為單一高性能機器工作的集群。
核心組件：

• Job Dispatcher（作業調度器）：控制節點，分解主任務為子任務，生成線程並遷移代碼至遠程運行服務器，最終聚合結果。
• SubTask（子任務）：用戶定義類，實現 JobCodeInt 接口及 jobCode() 方法，封裝遠程執行邏輯。本地資源需在構造函數中初始化。
• RunServer（運行服務器）：遠程對象，接收 JobCodeInt 實例並在本地執行，返回 Object 結果。
• PseudoRemThr（偽遠程線程）：封裝線程與 SubTask 實例，選擇遠程主機並發送執行。
• HostSelector（主機選擇器）：自動選擇負載最低的主機；若為多處理器系統，可重複返回同一主機。

工作流程

1. 作業調度器分解任務，創建 SubTask 實例。
2. 創建 PseudoRemThr 實例，傳入 SubTask 及目標主機（可選）。
3. 啟動線程，調用 waitForResult() 等待完成。
4. 通過 getResult() 獲取結果（未完成返回 Boolean.FALSE），聚合最終結果。

運行服務器啟動時註冊 RMI，通知調度器就緒。

計算示例：平方根求和

任務：計算 1 到 10⁹ 所有整數平方根之和。分解為兩個子任務（1~3×10⁸ 和 3×10⁸+1~10⁹），分別在 333MHz Pentium II (Win98) 和 500MHz Pentium III (Win2K) 上並行執行。

public class Sqrt implements JobCodeInt {
    double dblStart, dblEnd, dblPartialSum;
    public Sqrt(double start, double end) { dblStart=start; dblEnd=end; }
    public Object jobCode() {
        dblPartialSum = 0;
        for(double i=dblStart; i<=dblEnd; i++) dblPartialSum += Math.sqrt(i);
        return new Double(dblPartialSum);
    }
}

調度器創建兩個 PseudoRemThr，指定遠程主機 IP:端口，聚合結果。

性能評價

• 並行執行：120,000~128,000 ms
• 本地單線程：183,241~237,641 ms

任務量越大，並行優勢越明顯（通信開銷佔比下降）。結論：偽遠程線程適合計算密集型大任務。

優勢與展望

• 跨平台、異構集群支持；複用 Java 標準庫；無需內存管理。
• 缺點：性能依賴 JRE。
• 未來：互聯網即巨大異構集群，可部署於 Web 形成單一 Java 超級計算機；LAN 易構建微型超算。