FutureTask 和 CompletableFuture 雖然都用于異步編程，但它們在設計理念、功能性和適用場景上有著天壤之別。

可以將 FutureTask 視為一把手動扳手，功能單一但可靠；而 CompletableFuture 則是一個智能電動工具套裝，功能強大且自動化程度高。

以下是它們的詳細區(qū)別，我用一個表格進行概括，然后深入解釋：

一、核心區(qū)別對比表

二、深入解析關鍵區(qū)別

1. 核心設計理念：任務 (Task) vs. 階段 (Stage)

這是最根本的區(qū)別。

• FutureTask： 它的核心是包裝一個任務（Callable 或 Runnable）。你創(chuàng)建一個 FutureTask 對象，把它丟給一個線程去執(zhí)行，然后它代表那個單一任務的執(zhí)行結果。它的關注點是“執(zhí)行”這個動作本身。
• CompletableFuture： 它的核心是代表一個異步計算的階段。它源自 CompletionStage 接口。你不需要關心這個階段背后的任務是如何被執(zhí)行的（可能是線程池，也可能是其他方式）。你更關心的是這個階段完成后要做什么，以及它如何與其他階段連接起來。它的關注點是“組合與流轉”。

2. 結果獲取方式：阻塞 vs. 非阻塞回調

• FutureTask：

  FutureTask<String> futureTask = new FutureTask<>(() -> "Result");
  new Thread(futureTask).start();
  
  // 你必須主動調用 get()，線程會在此阻塞直到結果可用
  String result = futureTask.get(); // <- 阻塞點！
  

  問題：get() 方法是阻塞的，在等待結果時線程無法做其他事情，浪費資源。

• CompletableFuture：

  CompletableFuture.supplyAsync(() -> "Result")
                   .thenAccept(result -> System.out.println("Got: " + result)); // 非阻塞回調
                   
  // 主線程可以立即繼續(xù)執(zhí)行，無需等待
  System.out.println("Main thread continues...");
  

  優(yōu)勢：通過 thenAccept, thenApply 等回調方法，注冊一個動作，當結果可用時自動執(zhí)行。調用線程不會被阻塞，極大地提高了系統(tǒng)的吞吐量。

3. 組合與鏈式編程：無能 vs. 強大

這是 CompletableFuture 碾壓性優(yōu)勢的地方。

• FutureTask： 幾乎沒有組合能力。如果你想在任務A完成后，將其結果傳給任務B，你需要手動管理：

  FutureTask<String> taskA = ...;
  FutureTask<String> taskB = new FutureTask<>(() -> {
      String aResult = taskA.get(); // 這里會阻塞任務B的執(zhí)行線程！
      return process(aResult);
  });
  new Thread(taskB).start();
  

  這種方式既笨拙又會導致線程阻塞，無法高效利用資源。

• CompletableFuture： 提供了一整套函數式的流式操作符。

  • thenCompose() (扁平化映射): 用于串聯兩個有依賴關系的異步任務。

    CompletableFuture<String> future = getUserAsync(id)
        .thenCompose(user -> getOrderAsync(user)); // 返回 CompletableFuture<String>
    

  • thenCombine() (合并結果): 合并兩個獨立異步任務的結果。

    CompletableFuture<Double> future = getPriceAsync()
        .thenCombine(getTaxRateAsync(), (price, rate) -> price * rate);
    

  • allOf() / anyOf(): 等待所有任務完成或任意一個任務完成。

    CompletableFuture<Void> all = CompletableFuture.allOf(future1, future2, future3);
    all.thenRun(() -> /* 所有任務都完成了 */);
    

4. 異常處理：粗暴 vs. 優(yōu)雅

• FutureTask： 任務執(zhí)行中的異常會被捕獲，然后在調用 get() 時包裝成 ExecutionException 拋出。你只能在一個集中的地方進行 try-catch，處理邏輯不靈活。

  try {
      futureTask.get();
  } catch (ExecutionException e) {
      Throwable cause = e.getCause(); // 獲取真正的異常
      // 處理異常
  }
  

• CompletableFuture： 提供了流式的異常處理機制，可以非常優(yōu)雅地在流水線的任何一步進行恢復或處理。

  • exceptionally()： 類似于 catch，提供降級結果。

    CompletableFuture.supplyAsync(() -> mightFail())
                     .exceptionally(ex -> "Default Value");
    

  • handle()： 類似于 finally，無論成功失敗都會執(zhí)行，并可轉換結果。

    .handle((result, ex) -> {
        if (ex != null) {
            return "Recovered from: " + ex.getMessage();
        }
        return result;
    });
    

三、總結與選擇建議

結論：FutureTask 是一個更底層、更基礎的構建塊，是 ExecutorService 框架的基石。而 CompletableFuture 是一個站在 FutureTask 等基礎組件之上的、更高級的、面向現代異步編程需求的API和編程模型。對于新項目，絕大多數情況下都應優(yōu)先使用 CompletableFuture。

到此這篇關于Java中FutureTask 和 CompletableFuture的區(qū)別的文章就介紹到這了,更多相關Java FutureTask 和 CompletableFuture內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

最新評論