runAsync 方法接收的是 Runnable 的實例，但是它沒有返回值

supplyAsync 方法是JDK8函數(shù)式接口，無參數(shù)，會返回一個結(jié)果

這兩個方法是 executor 的升級，表示讓任務(wù)在指定的線程池中執(zhí)行，不指定的話，通常任務(wù)是在 ForkJoinPool.commonPool() 線程池中執(zhí)行的。

靜態(tài)方法runAsync和supplyAsync允許我們相應(yīng)地從Runnable和Supplier功能類型中創(chuàng)建CompletableFuture實例。

該Runnable的接口是在線程使用舊的接口，它不允許返回值。

Supplier接口是一個不具有參數(shù)，并返回參數(shù)化類型的一個值的單個方法的通用功能接口。

這允許將Supplier的實例作為lambda表達(dá)式提供，該表達(dá)式執(zhí)行計算并返回結(jié)果：

CompletableFuture future
  = CompletableFuture.supplyAsync(() -> "Hello");
 
// ...
 
assertEquals("Hello", future.get());

在兩個任務(wù)任務(wù)A，任務(wù)B中，如果既不需要任務(wù)A的值也不想在任務(wù)B中引用，那么你可以將Runnable lambda 傳遞給thenRun()方法。在下面的示例中，在調(diào)用future.get()方法之后，我們只需在控制臺中打印一行：

模板

CompletableFuture.runAsync(() -> {}).thenRun(() -> {}); 
CompletableFuture.supplyAsync(() -> "resultA").thenRun(() -> {});

第一行用的是 thenRun(Runnable runnable)，任務(wù) A 執(zhí)行完執(zhí)行 B，并且 B 不需要 A 的結(jié)果。

第二行用的是 thenRun(Runnable runnable)，任務(wù) A 執(zhí)行完執(zhí)行 B，會返回resultA，但是 B 不需要 A 的結(jié)果。

實戰(zhàn)

CompletableFuture completableFuture 
  = CompletableFuture.supplyAsync(() -> "Hello");
 
CompletableFuture future = completableFuture
  .thenRun(() -> System.out.println("Computation finished."));
 
future.get();

在兩個任務(wù)任務(wù)A，任務(wù)B中，如果你不需要在Future中有返回值，則可以用 thenAccept方法接收將計算結(jié)果傳遞給它。最后的future.get（）調(diào)用返回Void類型的實例。

模板

CompletableFuture.runAsync(() -> {}).thenAccept(resultA -> {}); 

CompletableFuture.supplyAsync(() -> "resultA").thenAccept(resultA -> {});

第一行中，runAsync不會有返回值，第二個方法thenAccept，接收到的resultA值為null，同時任務(wù)B也不會有返回結(jié)果

第二行中，supplyAsync有返回值，同時任務(wù)B不會有返回結(jié)果。

實戰(zhàn)

CompletableFuture completableFuture
  = CompletableFuture.supplyAsync(() -> "Hello");
 
CompletableFuture future = completableFuture
  .thenAccept(s -> System.out.println("Computation returned: " + s));
 
future.get();

在兩個任務(wù)任務(wù)A，任務(wù)B中，任務(wù)B想要任務(wù)A計算的結(jié)果，可以用thenApply方法來接受一個函數(shù)實例，用它來處理結(jié)果，并返回一個Future函數(shù)的返回值：

模板

CompletableFuture.runAsync(() -> {}).thenApply(resultA -> "resultB");
CompletableFuture.supplyAsync(() -> "resultA").thenApply(resultA -> resultA + " resultB");

第二行用的是 thenApply(Function fn)，任務(wù) A 執(zhí)行完執(zhí)行 B，B 需要 A 的結(jié)果，同時任務(wù) B 有返回值。

實戰(zhàn)

CompletableFuture completableFuture
  = CompletableFuture.supplyAsync(() -> "Hello");
 
CompletableFuture future = completableFuture
  .thenApply(s -> s + " World");
 
assertEquals("Hello World", future.get());

當(dāng)然，多個任務(wù)的情況下，如果任務(wù) B 后面還有任務(wù) C，往下繼續(xù)調(diào)用 .thenXxx() 即可。

接下來會有一個很有趣的設(shè)計模式；

CompletableFuture API 的最佳場景是能夠在一系列計算步驟中組合CompletableFuture實例。

這種組合結(jié)果本身就是CompletableFuture，允許進(jìn)一步再續(xù)組合。這種方法在函數(shù)式語言中無處不在，通常被稱為monadic設(shè)計模式。

簡單說，Monad就是一種設(shè)計模式，表示將一個運(yùn)算過程，通過函數(shù)拆解成互相連接的多個步驟。你只要提供下一步運(yùn)算所需的函數(shù)，整個運(yùn)算就會自動進(jìn)行下去。

在下面的示例中，我們使用thenCompose方法按順序組合兩個Futures。

請注意，此方法采用返回CompletableFuture實例的函數(shù)。該函數(shù)的參數(shù)是先前計算步驟的結(jié)果。這允許我們在下一個CompletableFuture的lambda中使用這個值：

CompletableFuture completableFuture 
  = CompletableFuture.supplyAsync(() -> "Hello")
    .thenCompose(s -> CompletableFuture.supplyAsync(() -> s + " World"));
 
assertEquals("Hello World", completableFuture.get());

該thenCompose方法連同thenApply一樣實現(xiàn)了結(jié)果的合并計算。但是他們的內(nèi)部形式是不一樣的，它們與Java 8中可用的Stream和Optional類的map和flatMap方法是有著類似的設(shè)計思路在里面的。

兩個方法都接收一個CompletableFuture并將其應(yīng)用于計算結(jié)果，但thenCompose（flatMap）方法接收一個函數(shù)，該函數(shù)返回相同類型的另一個CompletableFuture對象。此功能結(jié)構(gòu)允許將這些類的實例繼續(xù)進(jìn)行組合計算。

取兩個任務(wù)的結(jié)果

如果要執(zhí)行兩個獨(dú)立的任務(wù)，并對其結(jié)果執(zhí)行某些操作，可以用Future的thenCombine方法：

模板

CompletableFuture cfA = CompletableFuture.supplyAsync(() -> "resultA");
CompletableFuture cfB = CompletableFuture.supplyAsync(() -> "resultB");

cfA.thenAcceptBoth(cfB, (resultA, resultB) -> {});

cfA.thenCombine(cfB, (resultA, resultB) -> "result A + B");

實戰(zhàn)

CompletableFuture completableFuture 
  = CompletableFuture.supplyAsync(() -> "Hello")
    .thenCombine(CompletableFuture.supplyAsync(
      () -> " World"), (s1, s2) -> s1 + s2));
 
assertEquals("Hello World", completableFuture.get());

更簡單的情況是，當(dāng)你想要使用兩個Future結(jié)果時，但不需要將任何結(jié)果值進(jìn)行返回時，可以用thenAcceptBoth，它表示后續(xù)的處理不需要返回值，而 thenCombine 表示需要返回值：

CompletableFuture future = CompletableFuture.supplyAsync(() -> "Hello")
  .thenAcceptBoth(CompletableFuture.supplyAsync(() -> " World"),
    (s1, s2) -> System.out.println(s1 + s2));

在前面的部分中，我們展示了關(guān)于thenApply()和thenCompose()的示例。這兩個API都是使用的CompletableFuture調(diào)用，但這兩個API的使用是不同的。

此方法用于處理先前調(diào)用的結(jié)果。但是，要記住的一個關(guān)鍵點是返回類型是轉(zhuǎn)換泛型中的類型，是同一個CompletableFuture。

因此，當(dāng)我們想要轉(zhuǎn)換CompletableFuture 調(diào)用的結(jié)果時，效果是這樣的 ：

CompletableFuture finalResult = compute().thenApply(s-> s + 1);

該thenCompose()方法類似于thenApply()在都返回一個新的計算結(jié)果。但是，thenCompose()使用前一個Future作為參數(shù)。它會直接使結(jié)果變新的Future，而不是我們在thenApply()中到的嵌套Future，而是用來連接兩個CompletableFuture，是生成一個新的CompletableFuture：

CompletableFuture computeAnother(Integer i){
    return CompletableFuture.supplyAsync(() -> 10 + i);
}
CompletableFuture finalResult = compute().thenCompose(this::computeAnother);

因此，如果想要繼續(xù)嵌套鏈接CompletableFuture??方法，那么最好使用thenCompose()。

當(dāng)我們需要并行執(zhí)行多個任務(wù)時，我們通常希望等待所有它們執(zhí)行，然后處理它們的組合結(jié)果。

該CompletableFuture.allOf靜態(tài)方法允許等待所有的完成任務(wù)：

API

public static CompletableFuture allOf(CompletableFuture... cfs){...}

實戰(zhàn)

CompletableFuture future1  
  = CompletableFuture.supplyAsync(() -> "Hello");
CompletableFuture future2  
  = CompletableFuture.supplyAsync(() -> "Beautiful");
CompletableFuture future3  
  = CompletableFuture.supplyAsync(() -> "World");
 
CompletableFuture combinedFuture 
  = CompletableFuture.allOf(future1, future2, future3);
 
// ...
 
combinedFuture.get();
 
assertTrue(future1.isDone());
assertTrue(future2.isDone());
assertTrue(future3.isDone());

請注意，CompletableFuture.allOf()的返回類型是CompletableFuture 。這種方法的局限性在于它不會返回所有任務(wù)的綜合結(jié)果。相反，你必須手動從Futures獲取結(jié)果。幸運(yùn)的是，CompletableFuture.join()方法和Java 8 Streams API可以解決：

String combined = Stream.of(future1, future2, future3)
  .map(CompletableFuture::join)
  .collect(Collectors.joining(" "));
 
assertEquals("Hello Beautiful World", combined);

CompletableFuture 提供了 join() 方法，它的功能和 get() 方法是一樣的，都是阻塞獲取值，它們的區(qū)別在于 join() 拋出的是 unchecked Exception。這使得它可以在Stream.map（）方法中用作方法引用。

說到這里，我們順便來說下 CompletableFuture 的異常處理。這里我們要介紹兩個方法：

public CompletableFuture exceptionally(Function fn);
public  CompletionStage handle(BiFunction fn);

CompletableFuture.supplyAsync(() -> "resultA")
    .thenApply(resultA -> resultA + " resultB")
    .thenApply(resultB -> resultB + " resultC")
    .thenApply(resultC -> resultC + " resultD");

CompletableFuture future = CompletableFuture.supplyAsync(() -> {
    throw new RuntimeException();
})
        .exceptionally(ex -> "errorResultA")
        .thenApply(resultA -> resultA + " resultB")
        .thenApply(resultB -> resultB + " resultC")
        .thenApply(resultC -> resultC + " resultD");

System.out.println(future.join());

errorResultA resultB resultC resultD

String name = null;
 
// ...
 
CompletableFuture completableFuture  
  =  CompletableFuture.supplyAsync(() -> {
      if (name == null) {
          throw new RuntimeException("Computation error!");
      }
      return "Hello, " + name;
  })}).handle((s, t) -> s != null ? s : "Hello, Stranger!");
 
assertEquals("Hello, Stranger!", completableFuture.get());

CompletableFuture completableFuture  
  = CompletableFuture.supplyAsync(() -> "Hello");
 
CompletableFuture future = completableFuture
  .thenApplyAsync(s -> s + " World");
 
assertEquals("Hello World", future.get());