CompletableFuture.supplyAsync(() -> {
    try {
       TimeUnit.SECONDS.sleep(1);
    } catch (InterruptedException e) {
      throw new IllegalStateException(e);
    }
    return "Some Result"
}).thenApply(result -> {
    /* 
      Executed in the same thread where the supplyAsync() task is executed
      or in the main thread If the supplyAsync() task completes immediately (Remove sleep() call to verify)
    */
    return "Processed Result"
})

在以上示例中，在thenApply()中的任務(wù)和在supplyAsync()中的任務(wù)執(zhí)行在相同的線程中。任何supplyAsync()立即執(zhí)行完成,那就是執(zhí)行在主線程中（嘗試刪除sleep測試下）。
為了控制執(zhí)行回調(diào)任務(wù)的線程，你可以使用異步回調(diào)。如果你使用thenApplyAsync()回調(diào)，將從ForkJoinPool.commonPool()獲取不同的線程執(zhí)行。

CompletableFuture.supplyAsync(() -> {
    return "Some Result"
}).thenApplyAsync(result -> {
    // Executed in a different thread from ForkJoinPool.commonPool()
    return "Processed Result"
})

此外，如果你傳入一個Executor到thenApplyAsync()回調(diào)中，，任務(wù)將從Executor線程池獲取一個線程執(zhí)行。

Executor executor = Executors.newFixedThreadPool(2);
CompletableFuture.supplyAsync(() -> {
    return "Some result"
}).thenApplyAsync(result -> {
    // Executed in a thread obtained from the executor
    return "Processed Result"
}, executor);

1. 使用 thenCompose() 組合兩個獨立的future
假設(shè)你想從一個遠程API中獲取一個用戶的詳細信息，一旦用戶信息可用，你想從另外一個服務(wù)中獲取他的貸方。
考慮下以下兩個方法getUserDetail() 和getCreditRating()的實現(xiàn)：

CompletableFuture getUsersDetail(String userId) {
    return CompletableFuture.supplyAsync(() -> {
        UserService.getUserDetails(userId);
    });    
}

CompletableFuture getCreditRating(User user) {
    return CompletableFuture.supplyAsync(() -> {
        CreditRatingService.getCreditRating(user);
    });
}

現(xiàn)在讓我們弄明白當使用了thenApply()后是否會達到我們期望的結(jié)果-

CompletableFuture> result = getUserDetail(userId)
.thenApply(user -> getCreditRating(user));

在更早的示例中，Supplier函數(shù)傳入thenApply將返回一個簡單的值，但是在本例中，將返回一個CompletableFuture。以上示例的最終結(jié)果是一個嵌套的CompletableFuture。
如果你想獲取最終的結(jié)果給最頂層future，使用 thenCompose()方法代替-

CompletableFuture result = getUserDetail(userId)
.thenCompose(user -> getCreditRating(user));

因此，規(guī)則就是-如果你的回調(diào)函數(shù)返回一個CompletableFuture，但是你想從CompletableFuture鏈中獲取一個直接合并后的結(jié)果，這時候你可以使用thenCompose()。

2. 使用thenCombine()組合兩個獨立的 future
雖然thenCompose()被用于當一個future依賴另外一個future的時候用來組合兩個future。thenCombine()被用來當兩個獨立的Future都完成的時候，用來做一些事情。

System.out.println("Retrieving weight.");
CompletableFuture weightInKgFuture = CompletableFuture.supplyAsync(() -> {
    try {
        TimeUnit.SECONDS.sleep(1);
    } catch (InterruptedException e) {
       throw new IllegalStateException(e);
    }
    return 65.0;
});

System.out.println("Retrieving height.");
CompletableFuture heightInCmFuture = CompletableFuture.supplyAsync(() -> {
    try {
        TimeUnit.SECONDS.sleep(1);
    } catch (InterruptedException e) {
       throw new IllegalStateException(e);
    }
    return 177.8;
});

System.out.println("Calculating BMI.");
CompletableFuture combinedFuture = weightInKgFuture
        .thenCombine(heightInCmFuture, (weightInKg, heightInCm) -> {
    Double heightInMeter = heightInCm/100;
    return weightInKg/(heightInMeter*heightInMeter);
});

System.out.println("Your BMI is - " + combinedFuture.get());

當兩個Future都完成的時候，傳給``thenCombine()的回調(diào)函數(shù)將被調(diào)用。

我們使用thenCompose() 和 thenCombine()把兩個CompletableFuture組合在一起。現(xiàn)在如果你想組合任意數(shù)量的CompletableFuture，應(yīng)該怎么做？我們可以使用以下兩個方法組合任意數(shù)量的CompletableFuture。

static CompletableFuture allOf(CompletableFuture... cfs)
static CompletableFuture