20 張圖讓你搞定 CompletableFuture 異步編程

這時就需要我們調(diào)用 complete() 方法手動的結(jié)束一個 Future

completableFuture.complete("Future's?Result?Here?Manually");

這時，所有等待這個 Future 的 client 都會返回手動結(jié)束的指定結(jié)果

runAsync

使用 runAsync 進行異步計算

CompletableFuture?future?=?CompletableFuture.runAsync(()?->?{
????try?{
????????TimeUnit.SECONDS.sleep(3);
????}?catch?(InterruptedException?e)?{
????????throw?new?IllegalStateException(e);
????}
????System.out.println("運行在一個單獨的線程當中");
});

future.get();

由于使用的是 Runnable 函數(shù)式表達式，自然也不會獲取到結(jié)果

supplyAsync

使用 runAsync 是沒有返回結(jié)果的，我們想獲取異步計算的返回結(jié)果需要使用 supplyAsync() 方法

??CompletableFuture?future?=?CompletableFuture.supplyAsync(()?->?{
???try?{
????TimeUnit.SECONDS.sleep(3);
???}?catch?(InterruptedException?e)?{
????throw?new?IllegalStateException(e);
???}
???log.info("運行在一個單獨的線程當中");
???return?"我有返回值";
??});

??log.info(future.get());

由于使用的是 Supplier 函數(shù)式表達式，自然可以獲得返回結(jié)果

我們已經(jīng)多次說過，get() 方法在Future 計算完成之前會一直處在 blocking 狀態(tài)下，對于真正的異步處理，我們希望的是可以通過傳入回調(diào)函數(shù)，在Future 結(jié)束時自動調(diào)用該回調(diào)函數(shù)，這樣，我們就不用等待結(jié)果

CompletableFuture?comboText?=?CompletableFuture.supplyAsync(()?->?{
????//可以注釋掉做快速返回?start
???try?{
????TimeUnit.SECONDS.sleep(3);
???}?catch?(InterruptedException?e)?{
????throw?new?IllegalStateException(e);
???}
???log.info("?");
????//可以注釋掉做快速返回?end
???return?"贊";
??})
????.thenApply(first?->?{
?????log.info("在看");
?????return?first?+?",?在看";
????})
????.thenApply(second?->?second?+?",?轉(zhuǎn)發(fā)");

??log.info("三連有沒有？");
??log.info(comboText.get());

對 thenApply 的調(diào)用并沒有阻塞程序打印log，也就是前面說的通過回調(diào)通知機制， 這里你看到 thenApply ?使用的是supplyAsync所用的線程，如果將supplyAsync 做快速返回，我們再來看一下運行結(jié)果：

thenApply 此時使用的是主線程，所以：

串行的后續(xù)操作并不一定會和前序操作使用同一個線程

thenAccept

如果你不想從回調(diào)函數(shù)中返回任何結(jié)果，那可以使用 thenAccept

??final?CompletableFuture?voidCompletableFuture?=?CompletableFuture.supplyAsync(
????//?模擬遠端API調(diào)用，這里只返回了一個構造的對象
????()?->?Product.builder().id(12345L).name("頸椎/腰椎治療儀").build())
????.thenAccept(product?->?{
?????log.info("獲取到遠程API產(chǎn)品名稱?"?+?product.getName());
????});
??voidCompletableFuture.get();

thenRun

thenAccept 可以從回調(diào)函數(shù)中獲取前序執(zhí)行的結(jié)果，但thenRun 卻不可以，因為它的回調(diào)函數(shù)式表達式定義中沒有任何參數(shù)

CompletableFuture.supplyAsync(()?->?{
????//前序操作
}).thenRun(()?->?{
????//串行的后需操作，無參數(shù)也無返回值
});

我們前面同樣說過了，每個提供回調(diào)方法的函數(shù)都有兩個異步（Async）變體，異步就是另外起一個線程

??CompletableFuture?stringCompletableFuture?=?CompletableFuture.supplyAsync(()?->?{
???log.info("前序操作");
???return?"前需操作結(jié)果";
??}).thenApplyAsync(result?->?{
???log.info("后續(xù)操作");
???return?"后續(xù)操作結(jié)果";
??});

到這里，相信你串行的操作你已經(jīng)非常熟練了

thenCompose

日常的任務中，通常定義的方法都會返回 CompletableFuture 類型，這樣會給后續(xù)操作留有更多的余地，假如有這樣的業(yè)務（X唄是不是都有這樣的業(yè)務呢？）：

//獲取用戶信息詳情
?CompletableFuture?getUsersDetail(String?userId)?{
??return?CompletableFuture.supplyAsync(()?->?User.builder().id(12345L).name("日拱一兵").build());
?}

?//獲取用戶信用評級
?CompletableFuture?getCreditRating(User?user)?{
??return?CompletableFuture.supplyAsync(()?->?CreditRating.builder().rating(7.5).build().getRating());
?}

這時，如果我們還是使用 thenApply() 方法來描述串行關系，返回的結(jié)果就會發(fā)生 CompletableFuture 的嵌套

??CompletableFuture>?result?=?completableFutureCompose.getUsersDetail(12345L)
????.thenApply(user?->?completableFutureCompose.getCreditRating(user));

顯然這不是我們想要的，如果想“拍平” 返回結(jié)果，thenCompose 方法就派上用場了

CompletableFuture?result?=?completableFutureCompose.getUsersDetail(12345L)
????.thenCompose(user?->?completableFutureCompose.getCreditRating(user));

這個和 Lambda 的map 和 flatMap 的道理是一樣一樣滴

thenCombine

如果要聚合兩個獨立 Future 的結(jié)果，那么 thenCombine 就會派上用場了

??CompletableFuture?weightFuture?=?CompletableFuture.supplyAsync(()?->?65.0);
??CompletableFuture?heightFuture?=?CompletableFuture.supplyAsync(()?->?183.8);
??
??CompletableFuture?combinedFuture?=?weightFuture
????.thenCombine(heightFuture,?(weight,?height)?->?{
?????Double?heightInMeter?=?height/100;
?????return?weight/(heightInMeter*heightInMeter);
????});

??log.info("身體BMI指標?-?"?+?combinedFuture.get());

當然這里多數(shù)時處理兩個 Future 的關系，如果超過兩個Future，如何處理他們的一些聚合關系呢？

allOf ｜ anyOf

相信你看到方法的簽名，你已經(jīng)明白他的用處了，這里就不再介紹了

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