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"
})

此外，如果你傳入一個(gè)Executor到thenApplyAsync()回調(diào)中，，任務(wù)將從Executor線程池獲取一個(gè)線程執(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() 組合兩個(gè)獨(dú)立的future
假設(shè)你想從一個(gè)遠(yuǎn)程API中獲取一個(gè)用戶的詳細(xì)信息，一旦用戶信息可用，你想從另外一個(gè)服務(wù)中獲取他的貸方。
考慮下以下兩個(gè)方法getUserDetail() 和getCreditRating()的實(shí)現(xiàn)：

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

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

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

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

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

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

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

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

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());

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

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

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