CompletableFuture類中的其他方法一樣，也提供了一個(gè)以Async后綴結(jié)尾的版本thenComposeAsync。通常而言，名稱中不帶Async
的方法和它的前一個(gè)任務(wù)一樣，在同一個(gè)線程中運(yùn)行；而名稱以Async結(jié)尾的方法會(huì)將后續(xù)的任務(wù)提交到一個(gè)線程池，所以每個(gè)任務(wù)是由不同的線程處理的。

thenCombine方法，它接收名為BiFunction的第二參數(shù)，這個(gè)參數(shù)定義了當(dāng)兩個(gè)CompletableFuture對(duì)象完成計(jì)算后，結(jié)果如何合并。同thenCompose方法一樣，thenCombine方法也提供有一個(gè)Async的版本。這里，如果使用thenCombineAsync會(huì)導(dǎo)致BiFunction中定義的合并操作被提交到線程池中，由另一個(gè)任務(wù)以異步的方式執(zhí)行。

eg:有一家商店提供的價(jià)格是以歐元（EUR）計(jì)價(jià)的，但是你希望以美元的方式提供給你的客戶:

Future futurePriceInUSD = 
 CompletableFuture.supplyAsync(() -> shop.getPrice(product)) 
 .thenCombine( 
 CompletableFuture.supplyAsync( 
 () -> exchangeService.getRate(Money.EUR, Money.USD)), 
 (price, rate) -> price * rate 
 );

只要有商店返回商品價(jià)格就在第一時(shí)間顯示返回值，不再等待那些還未返回的商店（有些甚至?xí)l(fā)生超時(shí)）。Java 8的CompletableFuture通 過thenAccept方法提供了這一功能，它接收CompletableFuture執(zhí)行完畢后的返回值做參數(shù)。

重構(gòu)findPrices方法返回一個(gè)由Future構(gòu)成的流

public Stream> findPricesStream(String product) { 
 return shops.stream() 
 .map(shop -> CompletableFuture.supplyAsync( 
 () -> shop.getPrice(product), executor)) 
 .map(future -> future.thenApply(Quote::parse)) 
 .map(future -> future.thenCompose(quote -> 
 CompletableFuture.supplyAsync( 
 () -> Discount.applyDiscount(quote), executor))); 
}

findPricesStream("myPhone").map(f -> f.thenAccept(System.out::println));

由 于thenAccept方法已經(jīng)定義了如何處理CompletableFuture返回的結(jié)果，一旦CompletableFuture計(jì)算得到結(jié)果，它就返回一個(gè)CompletableFuture。對(duì)這個(gè)>對(duì)象，你能做的事非常有限，只能等待其運(yùn)行結(jié)束。

你還希望能給最慢的商店一些機(jī)會(huì)，讓它有機(jī)會(huì)打印輸出返回的價(jià)格。為了實(shí)現(xiàn)這一目的，你可以把構(gòu)成Stream的所有CompletableFuture對(duì)象放到一個(gè)數(shù)組中，等待所有的任務(wù)執(zhí)行完成，代碼如下所示：

CompletableFuture[] futures = findPricesStream("myPhone") 
 .map(f -> f.thenAccept(System.out::println)) 
 .toArray(size -> new CompletableFuture[size]); 
CompletableFuture.allOf(futures).join();

allOf工廠方法接收一個(gè)由CompletableFuture構(gòu)成的數(shù)組，數(shù)組中的所有CompletableFuture對(duì)象執(zhí)行完成之后，它返回一個(gè)CompletableFuture對(duì)象。這意味著，如果你需要等待最初Stream中的所有 CompletableFuture對(duì)象執(zhí)行完畢，對(duì) allOf方法返回的
CompletableFuture執(zhí)行join操作是個(gè)不錯(cuò)的主意。

你可能希望只要CompletableFuture對(duì)象數(shù)組中有任何一個(gè)執(zhí)行完畢就不再等待，比如，你正在查詢兩個(gè)匯率服務(wù)器，任何一個(gè)返回了結(jié)果都能滿足你的需求。在這種情況下，你可以使用一個(gè)類似的工廠方法anyOf。該方法接收一個(gè)CompletableFuture對(duì)象構(gòu)成的數(shù)組，返回由第一個(gè)執(zhí)行完畢的CompletableFuture對(duì)象的返回值構(gòu)成的CompletableFuture