Java Future 模式深度解析：異步調用的經典實現與源碼級剖析

Future 模式是異步編程的經典設計模式，核心思想：調用者立即拿到「提貨單」，背後啟動線程生產「真實貨物」，調用者稍後憑單取貨。本文基於經典「蛋糕店」案例，從角色協作、源碼流程、同步機制、擴展方向四個維度深度剖析。

一、角色劇本：蛋糕店比喻

二、完整源碼流程追蹤

1. 客戶下單

public class Main {
    public static void main(String[] args) {
        Host host = new Host();
        Data d1 = host.request(10, 'A'); // 立即返回 FutureData
        Data d2 = host.request(20, 'B');
        Data d3 = host.request(30, 'C');

        // 做其他事...
        try { Thread.sleep(200); } catch (InterruptedException ignored) {}

        // 取貨：阻塞直到就緒
        System.out.println(d1.getContent());
        System.out.println(d2.getContent());
        System.out.println(d3.getContent());
    }
}

2. 老闆接單

public class Host {
    public Data request(final int count, final char c) {
        // (1) 造提貨單
        final FutureData future = new FutureData();

        // (2) 派徒弟（新線程）做蛋糕
        new Thread(() -> {
            RealData real = new RealData(count, c); // 耗時操作
            future.setRealData(real);               // 填充提貨單
        }).start();

        // (3) 立即回單
        return future;
    }
}

3. 徒弟做蛋糕

public class RealData implements Data {
    private final String content;
    public RealData(int count, char c) {
        char[] buf = new char[count];
        for (int i = 0; i < count; i++) {
            buf[i] = c;
            try { Thread.sleep(1000); } catch (InterruptedException ignored) {} // 模擬耗時
        }
        content = new String(buf);
    }
    public String getContent() { return content; }
}

4. 提貨單內部機制

public class FutureData implements Data {
    private RealData realData;
    private boolean ready = false;

    public synchronized void setRealData(RealData rd) {
        if (ready) return; // 冪等
        this.realData = rd;
        ready = true;
        notifyAll(); // 喚醒所有等待線程
    }

    public synchronized String getContent() {
        while (!ready) { // while 防虛假喚醒
            try { wait(); } catch (InterruptedException ignored) {}
        }
        return realData.getContent();
    }
}

三、核心同步機制圖解

時間軸：
Client主線程:  request() ──────▶ 其他工作 ──────▶ getContent() [WAIT] ──────▶ 返回結果
                     │                                      ▲
                     ▼                                      │
Host請求線程:     new FutureData()                          │
                     │                                      │
                     ▼                                      │
徒弟線程:         RealData構造(慢) ──▶ setRealData() ──▶ notifyAll()
                                                                 │
                                                                 └── 唤醒 Client 主線程

關鍵點

• synchronized 保證 ready 可見性與原子性。
• while (!ready) wait() 模式防虛假喚醒、防重複通知。
• notifyAll() 而非 notify()：避免多條件等待時喚醒錯誤線程（此處單條件可用 notify）。
• 每個請求獨立線程、獨立 FutureData，客戶間無競爭，隔離性好。

四、與 JDK FutureTask/CompletableFuture 映射

五、擴展增強方向

1. 超時獲取：getContent(long timeout, TimeUnit unit) → wait(timeout)，超時拋 TimeoutException。
2. 取消支持：添加 cancelled 標誌，getContent() 檢查拋 CancellationException，徒弟線程定期檢查 Thread.interrupted() 停止工作。
3. 進度回調：FutureData.addProgressListener(ProgressListener l)，徒弟線程周期性通知進度。
4. 異常傳播：setException(Throwable) 存儲異常，getContent() 重新拋出（包裝為 ExecutionException）。
5. 併發合併：allOf(futures...)、anyOf(futures...) 等待多個提貨單。

六、常見誤區

• 以為 FutureData 就是異步：它只是同步等待的協調器，異步性來自獨立線程構建 RealData。
• 忽略 while 循環：直接 if (!ready) wait() 會導致虛假喚醒後邏輯錯誤。
• 共享 FutureData：多客戶共用一個提貨單會導致數據錯亂，每請求一個 FutureData。
• 在 RealData 構造器中拋異常未處理：導致 setRealData 永不調用，客戶永久阻塞。必須 try-catch 並調用 setException。

Future 模式以極簡的同步原語實現了生產者-消費者解耦，是理解 FutureTask、CompletableFuture、Actor 模型、Reactive Streams 等高級異步框架的基石。建議手寫一遍本文代碼，體會 wait/notify 與狀態機的協舞之美。

1. 上一篇文章： Java 異步回調實戰：Future 模式、CompletableFuture 與自定義回調接口
2. 下一篇文章： Java 多線程實現異步調用：Future 模式完整實戰與線程池優化

Java 相關知識

解決 Eclipse 無法除錯 J2ME 程式的設定技巧

問題現象 在 Eclipse 中對 J2ME 專案進行除錯時

純 Java 實作：在 Windows 環境下讀取 MAC 位址

引言 Java 跨平台特性雖強，但某些場景（如軟體授權綁定硬

在 J2EE 伺服器環境中整合 Apache Derby 資料庫

前言 應用程式伺服器作為連結後端資料來源與前端用戶的中介層，

《Java核心編程 卷1：基礎》深度書評：從入門到精通的經典之作

踏入21世紀，Java圖書已經琳瑯滿目，但回首Java剛誕生