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()中的任務和在supplyAsync()中的任務執行在相同的線程中。任何supplyAsync()立即執行完成,那就是執行在主線程中（嘗試刪除sleep測試下）。
為了控制執行回調任務的線程，你可以使用異步回調。如果你使用thenApplyAsync()回調，將從ForkJoinPool.commonPool()獲取不同的線程執行。

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

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

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
假設你想從一個遠程API中獲取一個用戶的詳細信息，一旦用戶信息可用，你想從另外一個服務中獲取他的貸方。
考慮下以下兩個方法getUserDetail() 和getCreditRating()的實現：

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

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

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

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

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

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

因此，規則就是-如果你的回調函數返回一個CompletableFuture，但是你想從CompletableFuture鏈中獲取一個直接合并后的結果，這時候你可以使用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()的回調函數將被調用。

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

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