Java?CompletableFuture實(shí)現(xiàn)多線程異步編排
更新時(shí)間：2022年09月07日 14:55:46 作者：yyp技術(shù)
這篇文章主要為大家介紹了Java?CompletableFuture實(shí)現(xiàn)多線程異步編排，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
一 ：?jiǎn)栴}背景
問(wèn)題：當(dāng)查詢接口較復(fù)雜時(shí)候，數(shù)據(jù)的獲取都需要[遠(yuǎn)程調(diào)用]，必然需要花費(fèi)更多的時(shí)間。 假如查詢文章詳情頁(yè)面，需要如下標(biāo)注的時(shí)間才能完成，比如如下場(chǎng)景：
1. 查詢文章詳情 0.5s
2. 查詢文章博主個(gè)人信息 0.5s
3. 查詢文章評(píng)論 1s
4. 查詢博主相關(guān)文章分類(lèi) 1s
5. 相關(guān)推薦文章 1s
上面的描述只是舉個(gè)例子不要在意這里的查詢描述，看實(shí)際情況使用，有些相關(guān)的查詢我們可以拆分接口實(shí)現(xiàn)，上面的描述只是為了舉例子。
那么，用戶需要4s后才能統(tǒng)計(jì)的數(shù)據(jù)。很顯然是不能接受的。 如果有多個(gè)線程同時(shí)完成這4步操作，也許只需要1s左右即可完成響應(yīng)。
二 ：CompletableFuture介紹
在Java 8中, 新增加了一個(gè)包含50個(gè)方法左右的類(lèi): CompletableFuture，提供了非常強(qiáng)大的Future的擴(kuò)展功能，可以幫助我們簡(jiǎn)化異步編程的復(fù)雜性，提供了函數(shù)式編程的能力，可以通過(guò)回調(diào)的方式處理計(jì)算結(jié)果，并且提供了轉(zhuǎn)換和組合CompletableFuture的方法。
CompletableFuture類(lèi)實(shí)現(xiàn)了Future接口，所以你還是可以像以前一樣通過(guò)get方法阻塞或者輪詢的方式獲得結(jié)果，但是這種方式不推薦使用。 CompletableFuture和FutureTask同屬于Future接口的實(shí)現(xiàn)類(lèi)，都可以獲取線程的執(zhí)行結(jié)果。
三 ：具體場(chǎng)景
1.0 單個(gè)任務(wù)
1.0.1 runAsync：無(wú)返回值
/**
* runAsync無(wú)返回值
*/
CompletableFuture<Void> completableFuture = CompletableFuture.runAsync(() -> {
System.out.println("當(dāng)前線程" + Thread.currentThread().getId());
int i = 10 / 2;
System.out.println("運(yùn)行結(jié)果：" + i);
}, executor);
1.0.2 supplyAsync：有返回值
whenComplete：能感知異常，能感知結(jié)果，但沒(méi)辦法給返回值
exceptionally：能感知異常，不能感知結(jié)果，能給返回值。相當(dāng)于，如果出現(xiàn)異常就返回這個(gè)值
/**
* supplyAsync有返回值
* whenComplete能感知異常，能感知結(jié)果，但沒(méi)辦法給返回值
* exceptionally能感知異常，不能感知結(jié)果，能給返回值。相當(dāng)于，如果出現(xiàn)異常就返回這個(gè)值
*/
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
System.out.println("當(dāng)前線程" + Thread.currentThread().getId());
int i = 10 / 0;
System.out.println("運(yùn)行結(jié)果：" + i);
return i;
}, executor).whenComplete((res,excption)->{
//whenComplete雖然能得到異常信息，但是沒(méi)辦法修改返回值
System.out.println("異步任務(wù)成功完成...結(jié)果是："+res+";異常是："+excption);
}).exceptionally(throwable -> {
//exceptionally能感知異常，而且能返回一個(gè)默認(rèn)值，相當(dāng)于，如果出現(xiàn)異常就返回這個(gè)值
return 10;
});
1.0.3 supplyAsync：有返回值
handle能拿到返回結(jié)果，也能得到異常信息，也能修改返回值
/**
* supplyAsync有返回值
* handle能拿到返回結(jié)果，也能得到異常信息，也能修改返回值
*/
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
System.out.println("當(dāng)前線程" + Thread.currentThread().getId());
int i = 10 / 4;
System.out.println("運(yùn)行結(jié)果：" + i);
return i;
}, executor).handle((res,excption)->{
if(excption!=null){
return 0;
}else {
return res * 2;
}
});
2.0 兩個(gè)任務(wù)編排
兩任務(wù)組合（線程串行化）
可以是兩任務(wù)的串行化，就是一個(gè)任務(wù)執(zhí)行完了再執(zhí)行下一個(gè)
也可以是多個(gè)任務(wù)的串行化，就是按照順序一個(gè)個(gè)的執(zhí)行
2.0.1 thenRunAsync
不能接收上一次的執(zhí)行結(jié)果，也沒(méi)返回值
/**
* thenRunXXX 不能接收上一次的執(zhí)行結(jié)果，也沒(méi)返回值
* .thenRunAsync(() -> {
* System.out.println("任務(wù)2啟動(dòng)了...");
* }, executor);
*/
CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> {
System.out.println("當(dāng)前線程" + Thread.currentThread().getId());
int i = 10 / 4;
System.out.println("運(yùn)行結(jié)果：" + i);
return i;
}, executor).thenRunAsync(() -> {
System.out.println("任務(wù)2啟動(dòng)了...");
}, executor);
2.0.2 thenAcceptAsync
能接收上一次的執(zhí)行結(jié)果，但沒(méi)返回值
/**
* thenAcceptXXX 能接收上一次的執(zhí)行結(jié)果，但沒(méi)返回值
* .thenAcceptAsync(res->{
* System.out.println("任務(wù)2啟動(dòng)了..."+res);
* },executor);
*/
CompletableFuture<Void> future = CompletableFuture.supplyAsync(() -> {
System.out.println("當(dāng)前線程" + Thread.currentThread().getId());
int i = 10 / 4;
System.out.println("運(yùn)行結(jié)果：" + i);
return i;
}, executor).thenAcceptAsync(res -> {
System.out.println("任務(wù)2啟動(dòng)了..." + res);
}, executor);
2.0.3 thenApplyAsync
能接收上一次的執(zhí)行結(jié)果，又可以有返回值
/**
* thenApplyXXX 能接收上一次的執(zhí)行結(jié)果，又可以有返回值
* .thenApplyAsync(res -> {
* System.out.println("任務(wù)2啟動(dòng)了..." + res);
* return "hello " + res;
* }, executor);
*/
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
System.out.println("當(dāng)前線程" + Thread.currentThread().getId());
int i = 10 / 4;
System.out.println("運(yùn)行結(jié)果：" + i);
return i;
}, executor).thenApplyAsync(res -> {
System.out.println("任務(wù)2啟動(dòng)了..." + res);
return "hello " + res;
}, executor);
3.0 三任務(wù)編排
先準(zhǔn)備兩個(gè)任務(wù)
CompletableFuture<Object> future01 =CompletableFuture.supplyAsync(() -> {
System.out.println("任務(wù)1線程" + Thread.currentThread().getId());
int i = 10 / 4;
System.out.println("任務(wù)1結(jié)束：");
return i;
}, executor);
CompletableFuture<Object> future02 = CompletableFuture.supplyAsync(() -> {
System.out.println("任務(wù)2線程" + Thread.currentThread().getId());
try {
Thread.sleep(3000);
System.out.println("任務(wù)2結(jié)束：");
} catch (InterruptedException e) {
e.printStackTrace();
}
return "hello";
}, executor);
3.0.1 三任務(wù)組合
前兩個(gè)任務(wù)都完成，才執(zhí)行任務(wù)3
3.0.1-1、runAfterBothAsync：任務(wù)01 任務(wù)02都完成了，再開(kāi)始執(zhí)行任務(wù)3，不感知任務(wù)1、2的結(jié)果的，也沒(méi)返回值
CompletableFuture<Void> future = future01.runAfterBothAsync(future02, () -> {
System.out.println("任務(wù)3開(kāi)始");
}, executor);
3.0.1-2、thenAcceptBothAsync：任務(wù)01 任務(wù)02都完成了，再開(kāi)始執(zhí)行任務(wù)3，能感知到任務(wù)1、2的結(jié)果，但沒(méi)返回值
CompletableFuture<Void> future = future01.thenAcceptBothAsync(future02, (f1, f2) -> {
System.out.println("任務(wù)3開(kāi)始...得到之前的結(jié)果：f1:" + f1 + ", f2:" + f2);
}, executor);
3.0.1-3、 thenCombineAsync：任務(wù)01 任務(wù)02都完成了，再開(kāi)始執(zhí)行任務(wù)3，能感知到任務(wù)1、2的結(jié)果，而且自己可以帶返回值
CompletableFuture<String> future = future01.thenCombineAsync(future02, (f1, f2) -> {
return f1+":"+f2+"：哈哈";
}, executor);
3.0.2 三任務(wù)組合二
前兩個(gè)任務(wù)只要有一個(gè)完成，就執(zhí)行任務(wù)3
3.0.2-1、runAfterEitherAsync：兩個(gè)任務(wù)只要有一個(gè)完成，就執(zhí)行任務(wù)3，不感知結(jié)果，自己沒(méi)返回值
CompletableFuture<Void> future = future01.runAfterEitherAsync(future02, () -> {
System.out.println("任務(wù)3開(kāi)始...");
}, executor);
3.0.2-2、 acceptEitherAsync：兩個(gè)任務(wù)只要有一個(gè)完成，就執(zhí)行任務(wù)3，感知結(jié)果，自己沒(méi)返回值
CompletableFuture<Void> future = future01.acceptEitherAsync(future02, (res) -> {
System.out.println("任務(wù)3開(kāi)始...之前的結(jié)果" + res);
}, executor);
3.0.2-3、applyToEitherAsync：兩個(gè)任務(wù)只要有一個(gè)完成，就執(zhí)行任務(wù)3，感知結(jié)果，自己有返回值
CompletableFuture<String> future = future01.applyToEitherAsync(future02, (res) -> {
System.out.println("任務(wù)3開(kāi)始...之前的結(jié)果" + res);
return "任務(wù)3的結(jié)果...";
}, executor);
4.0 多任務(wù)的編排
/**
* 多任務(wù)組合
*/
CompletableFuture<String> futureImg = CompletableFuture.supplyAsync(() -> {
System.out.println("查詢商品圖片信息");
return "hello.jpg";
},executor);
CompletableFuture<String> futureAttr = CompletableFuture.supplyAsync(() -> {
System.out.println("查詢商品屬性信息");
return "黑色+256G";
},executor);
CompletableFuture<String> futureDesc = CompletableFuture.supplyAsync(() -> {
try {
Thread.sleep(3000);
System.out.println("查詢商品介紹信息");
} catch (InterruptedException e) {
e.printStackTrace();
}
return "華為...";
},executor);
4.0.1、allOf：所有任務(wù)都執(zhí)行完
/**
* allOf 所有任務(wù)都執(zhí)行完
*/
CompletableFuture<Void> allOf = CompletableFuture.allOf(futureImg, futureAttr, futureDesc);
allOf.get();//等待所有結(jié)果完成
4.0.2、anyOf：其中有一個(gè)任務(wù)執(zhí)行完就可以
/**
* anyOf 其中有一個(gè)任務(wù)執(zhí)行完就可以
*/
CompletableFuture<Object> anyOf = CompletableFuture.anyOf(futureImg, futureAttr, futureDesc);
anyOf.get();
四： 一個(gè)實(shí)際的例子
public SkuItemVo item(Long skuId) {
SkuItemVo skuItemVo = new SkuItemVo();
//1、sku詳細(xì)信息 sku_info
SkuInfoEntity skuInfo = getById(skuId);
skuItemVo.setInfo(skuInfo);
//2、sku 圖片信息 sku_img
List<SkuImagesEntity> images = skuImagesService.getImagesBySkuId(skuId);
skuItemVo.setImages(images);
//3、spu 銷(xiāo)售屬性組合
List<SkuItemSaleAttrVo> saleAttr = skuSaleAttrValueService.getSaleAttrBySpuId(skuInfo.getSpuId());
skuItemVo.setSaleAttr(saleAttr);
//4、spu 的介紹
SpuInfoDescEntity spuInfoDesc = spuInfoDescService.getById(skuInfo.getSpuId());
skuItemVo.setDesc(spuInfoDesc);
//5、spu 規(guī)格參數(shù)信息
List<SpuItemAttrGroupVo> groupAttrs = attrGroupService.getAttrGroupWithAttrsBySpuId(skuInfo.getSpuId(),skuInfo.getCatalogId());
skuItemVo.setGroupAttrs(groupAttrs);
return skuItemVo;
}
使用CompletableFuture異步編排后
private SkuItemVo item(Long skuId) {
SkuItemVo skuItemVo = new SkuItemVo();
/**
* 3、4、5需要依賴1的運(yùn)行結(jié)果，需要返回skuInfo后從中獲取spuId和catalogId
* 而2不需要依賴1的運(yùn)行結(jié)果
*/
//1、sku詳細(xì)信息 sku_info
CompletableFuture<SkuInfoEntity> infoFuture = CompletableFuture.supplyAsync(() -> {
SkuInfoEntity skuInfo = getById(skuId);
skuItemVo.setInfo(skuInfo);
return skuInfo;
}, executor);
//2、sku 圖片信息 sku_img 2不需要等待上邊1的執(zhí)行結(jié)果
CompletableFuture<Void> imageFuture = CompletableFuture.runAsync(() -> {
List<SkuImagesEntity> images = skuImagesService.getImagesBySkuId(skuId);
skuItemVo.setImages(images);
}, executor);
//下邊的3、4、5都需要上邊1的執(zhí)行結(jié)果
//所以下邊的3、4、5都是基于上邊1的執(zhí)行結(jié)果 infoFuture 開(kāi)始的
//都是以infoFuture.thenAcceptAsync(skuInfo -> {})開(kāi)始的
CompletableFuture<Void> saleAttrFuture = infoFuture.thenAcceptAsync(skuInfo -> {
//3、spu 銷(xiāo)售屬性組合 3
List<SkuItemSaleAttrVo> saleAttr = skuSaleAttrValueService.getSaleAttrBySpuId(skuInfo.getSpuId());
skuItemVo.setSaleAttr(saleAttr);
System.out.println(saleAttr);
}, executor);
CompletableFuture<Void> descFuture = infoFuture.thenAcceptAsync(skuInfo -> {
//4、spu 的介紹
SpuInfoDescEntity spuInfoDesc = spuInfoDescService.getById(skuInfo.getSpuId());
skuItemVo.setDesc(spuInfoDesc);
}, executor);
CompletableFuture<Void> attrGroupFuture = infoFuture.thenAcceptAsync(skuInfo -> {
//5、spu 規(guī)格參數(shù)信息
List<SpuItemAttrGroupVo> groupAttrs = attrGroupService.getAttrGroupWithAttrsBySpuId(skuInfo.getSpuId(),skuInfo.getCatalogId());
System.out.println(groupAttrs);
skuItemVo.setGroupAttrs(groupAttrs);
}, executor);
//等待所有任務(wù)完成
try {
CompletableFuture.allOf(saleAttrFuture,descFuture,attrGroupFuture,imageFuture).get() ;
} catch (InterruptedException e) {
log.error("查詢商品詳情異步編排錯(cuò)誤: ");
log.error(e.getMessage() );
} catch (ExecutionException e) {
log.error(e.getMessage() );
}
return skuItemVo;
}以上就是Java CompletableFuture實(shí)現(xiàn)多線程異步編排的詳細(xì)內(nèi)容，更多關(guān)于Java CompletableFuture的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
JAVA中數(shù)組插入與刪除指定元素的實(shí)例代碼
下面小編就為大家分享一篇JAVA中數(shù)組插入與刪除指定元素的實(shí)例代碼，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-02-02
這篇文章主要介紹了redis分布式鎖的原理及代碼實(shí)例,Redis作為一款高性能內(nèi)存數(shù)據(jù)庫(kù),其提供了一種非常實(shí)用的分布式鎖解決方案,可以幫助開(kāi)發(fā)人員輕松地實(shí)現(xiàn)分布式鎖功能,對(duì)于分布式系統(tǒng)的開(kāi)發(fā)和維護(hù),具有非常大的實(shí)用價(jià)值,需要的朋友可以參考下2024-01-01
對(duì)于java的變量天天見(jiàn)到，但有時(shí)候別人問(wèn)起它們的區(qū)別有時(shí)候也說(shuō)不全，所以就找了些資料整理了整理...2013-12-12
一篇文章總結(jié)Java虛擬機(jī)內(nèi)存區(qū)域模型
這篇文章主要介紹了一篇文章總結(jié)Java虛擬機(jī)內(nèi)存區(qū)域模型,本篇文章主要來(lái)總結(jié)一下Java虛擬機(jī)內(nèi)存的各個(gè)區(qū)域，以及這些區(qū)域的作用、服務(wù)對(duì)象以及其中可能產(chǎn)生的問(wèn)題，作為大家的面試寶典。,需要的朋友可以參考下2019-06-06
Java 超詳細(xì)講解ThreadLocal類(lèi)的使用
寫(xiě)SpringBoot項(xiàng)目的時(shí)候，經(jīng)常用到的一個(gè)保存用戶信息的類(lèi)就是Threadlocal，我們今天就來(lái)詳細(xì)介紹一下這個(gè)類(lèi)，感興趣的朋友來(lái)看看吧2022-04-04
下面小編就為大家?guī)?lái)一篇淺談java異常鏈與異常丟失。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2016-09-09
Spring?boot?easyexcel?實(shí)現(xiàn)復(fù)合數(shù)據(jù)導(dǎo)出、按模塊導(dǎo)出功能
這篇文章主要介紹了Spring?boot?easyexcel?實(shí)現(xiàn)復(fù)合數(shù)據(jù)導(dǎo)出、按模塊導(dǎo)出,實(shí)現(xiàn)思路流程是準(zhǔn)備一個(gè)導(dǎo)出基礎(chǔ)填充模板，默認(rèn)填充key，本文給大家介紹的非常詳細(xì)，需要的朋友可以參考下2023-09-09
繼承是java面向?qū)ο缶幊碳夹g(shù)的一塊基石，因?yàn)樗试S創(chuàng)建分等級(jí)層次的類(lèi)。繼承就是子類(lèi)繼承父類(lèi)的特征和行為，使得子類(lèi)對(duì)象（實(shí)例）具有父類(lèi)的實(shí)例域和方法，或子類(lèi)從父類(lèi)繼承方法，使得子類(lèi)具有父類(lèi)相同的行為2021-10-10
這篇文章主要介紹了Java中MapStruct使用方法解析,接受請(qǐng)求參數(shù)都會(huì)使用一個(gè)vo類(lèi),這個(gè)vo類(lèi)里封裝了所有需要接受的參數(shù),然后對(duì)參數(shù)進(jìn)行業(yè)務(wù)邏輯處理,處理完后會(huì)持久化處理,?使用MapStruct可以快速幫你解決轉(zhuǎn)換工作,需要的朋友可以參考下2023-10-10
Spring Boot可以讓你將配置外部化,這樣你就可以在不同的環(huán)境中使用相同的應(yīng)用程序代碼,這篇文章主要給大家介紹了關(guān)于Spring?Boot指定外部配置文件的相關(guān)資料,需要的朋友可以參考下2024-01-01