示例
@Test
publicvoidtestCompletableThenAccept()throwsExecutionException,InterruptedException{
longstartTime=System.currentTimeMillis();
CompletableFuturecp1=CompletableFuture.supplyAsync(()->{
return"dev";

});
CompletableFuturecp2=cp1.thenAccept((a)->{
System.out.println("上一個(gè)任務(wù)的返回結(jié)果為:"+a);
});

cp2.get();
}

3、 thenApply/thenApplyAsync

表示第一個(gè)任務(wù)執(zhí)行完成后，執(zhí)行第二個(gè)回調(diào)方法任務(wù)，會(huì)將該任務(wù)的執(zhí)行結(jié)果，作為入?yún)ⅲ瑐鬟f到回調(diào)方法中，并且回調(diào)方法是有返回值的。

示例

@Test
publicvoidtestCompletableThenApply()throwsExecutionException,InterruptedException{
CompletableFuturecp1=CompletableFuture.supplyAsync(()->{
return"dev";

}).thenApply((a)->{
if(Objects.equals(a,"dev")){
return"dev";
}
return"prod";
});

System.out.println("當(dāng)前環(huán)境為:"+cp1.get());

//輸出:當(dāng)前環(huán)境為:dev
}

異常回調(diào)

當(dāng)CompletableFuture的任務(wù)不論是正常完成還是出現(xiàn)異常它都會(huì)調(diào)用 「whenComplete」 這回調(diào)函數(shù)。

• 「正常完成」 ：whenComplete返回結(jié)果和上級(jí)任務(wù)一致，異常為null；
• 「出現(xiàn)異常」 ：whenComplete返回結(jié)果為null，異常為上級(jí)任務(wù)的異常；

即調(diào)用get()時(shí)，正常完成時(shí)就獲取到結(jié)果，出現(xiàn)異常時(shí)就會(huì)拋出異常，需要你處理該異常。

下面來(lái)看看示例

1、只用whenComplete

@Test
publicvoidtestCompletableWhenComplete()throwsExecutionException,InterruptedException{
CompletableFuturefuture=CompletableFuture.supplyAsync(()->{

if(Math.random()0.5){
thrownewRuntimeException("出錯(cuò)了");
}
System.out.println("正常結(jié)束");
return0.11;

}).whenComplete((aDouble,throwable)->{
if(aDouble==null){
System.out.println("whenCompleteaDoubleisnull");
}else{
System.out.println("whenCompleteaDoubleis"+aDouble);
}
if(throwable==null){
System.out.println("whenCompletethrowableisnull");
}else{
System.out.println("whenCompletethrowableis"+throwable.getMessage());
}
});
System.out.println("最終返回的結(jié)果="+future.get());
}

正常完成，沒(méi)有異常時(shí)：

正常結(jié)束
whenCompleteaDoubleis0.11
whenCompletethrowableisnull
最終返回的結(jié)果=0.11

出現(xiàn)異常時(shí)：get()會(huì)拋出異常

whenCompleteaDoubleisnull
whenCompletethrowableisjava.lang.RuntimeException:出錯(cuò)了

java.util.concurrent.ExecutionException:java.lang.RuntimeException:出錯(cuò)了
atjava.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
atjava.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895)

2、whenComplete + exceptionally示例

@Test
publicvoidtestWhenCompleteExceptionally()throwsExecutionException,InterruptedException{
CompletableFuturefuture=CompletableFuture.supplyAsync(()->{
if(Math.random()0.5){
thrownewRuntimeException("出錯(cuò)了");
}
System.out.println("正常結(jié)束");
return0.11;

}).whenComplete((aDouble,throwable)->{
if(aDouble==null){
System.out.println("whenCompleteaDoubleisnull");
}else{
System.out.println("whenCompleteaDoubleis"+aDouble);
}
if(throwable==null){
System.out.println("whenCompletethrowableisnull");
}else{
System.out.println("whenCompletethrowableis"+throwable.getMessage());
}
}).exceptionally((throwable)->{
System.out.println("exceptionally中異常："+throwable.getMessage());
return0.0;
});

System.out.println("最終返回的結(jié)果="+future.get());
}

當(dāng)出現(xiàn)異常時(shí)，exceptionally中會(huì)捕獲該異常，給出默認(rèn)返回值0.0。

whenCompleteaDoubleisnull
whenCompletethrowableisjava.lang.RuntimeException:出錯(cuò)了
exceptionally中異常：java.lang.RuntimeException:出錯(cuò)了
最終返回的結(jié)果=0.0

多任務(wù)組合回調(diào)

1、AND組合關(guān)系

thenCombine / thenAcceptBoth / runAfterBoth都表示：「當(dāng)任務(wù)一和任務(wù)二都完成再執(zhí)行任務(wù)三」 。

區(qū)別在于：

• 「runAfterBoth」 不會(huì)把執(zhí)行結(jié)果當(dāng)做方法入?yún)ⅲ覜](méi)有返回值
• 「thenAcceptBoth」 : 會(huì)將兩個(gè)任務(wù)的執(zhí)行結(jié)果作為方法入?yún)ⅲ瑐鬟f到指定方法中，且無(wú)返回值
• 「thenCombine」 ：會(huì)將兩個(gè)任務(wù)的執(zhí)行結(jié)果作為方法入?yún)ⅲ瑐鬟f到指定方法中，且有返回值

示例

@Test
publicvoidtestCompletableThenCombine()throwsExecutionException,InterruptedException{
//創(chuàng)建線(xiàn)程池
ExecutorServiceexecutorService=Executors.newFixedThreadPool(10);
//開(kāi)啟異步任務(wù)1
CompletableFuturetask=CompletableFuture.supplyAsync(()->{
System.out.println("異步任務(wù)1，當(dāng)前線(xiàn)程是："+Thread.currentThread().getId());
intresult=1+1;
System.out.println("異步任務(wù)1結(jié)束");
returnresult;
},executorService);

//開(kāi)啟異步任務(wù)2
CompletableFuturetask2=CompletableFuture.supplyAsync(()->{
System.out.println("異步任務(wù)2，當(dāng)前線(xiàn)程是："+Thread.currentThread().getId());
intresult=1+1;
System.out.println("異步任務(wù)2結(jié)束");
returnresult;
},executorService);

//任務(wù)組合
CompletableFuturetask3=task.thenCombineAsync(task2,(f1,f2)->{
System.out.println("執(zhí)行任務(wù)3，當(dāng)前線(xiàn)程是："+Thread.currentThread().getId());
System.out.println("任務(wù)1返回值："+f1);
System.out.println("任務(wù)2返回值："+f2);
returnf1+f2;
},executorService);

Integerres=task3.get();
System.out.println("最終結(jié)果："+res);
}

「運(yùn)行結(jié)果」

異步任務(wù)1，當(dāng)前線(xiàn)程是：17
異步任務(wù)1結(jié)束
異步任務(wù)2，當(dāng)前線(xiàn)程是：18
異步任務(wù)2結(jié)束
執(zhí)行任務(wù)3，當(dāng)前線(xiàn)程是：19
任務(wù)1返回值：2
任務(wù)2返回值：2
最終結(jié)果：4

2、OR組合關(guān)系

applyToEither / acceptEither / runAfterEither 都表示：「兩個(gè)任務(wù)，只要有一個(gè)任務(wù)完成，就執(zhí)行任務(wù)三」 。

區(qū)別在于：

• 「runAfterEither」 ：不會(huì)把執(zhí)行結(jié)果當(dāng)做方法入?yún)ⅲ覜](méi)有返回值
• 「acceptEither」 : 會(huì)將已經(jīng)執(zhí)行完成的任務(wù)，作為方法入?yún)ⅲ瑐鬟f到指定方法中，且無(wú)返回值
• 「applyToEither」 ：會(huì)將已經(jīng)執(zhí)行完成的任務(wù)，作為方法入?yún)ⅲ瑐鬟f到指定方法中，且有返回值

示例

@Test
publicvoidtestCompletableEitherAsync(){
//創(chuàng)建線(xiàn)程池
ExecutorServiceexecutorService=Executors.newFixedThreadPool(10);
//開(kāi)啟異步任務(wù)1
CompletableFuturetask=CompletableFuture.supplyAsync(()->{
System.out.println("異步任務(wù)1，當(dāng)前線(xiàn)程是："+Thread.currentThread().getId());

intresult=1+1;
System.out.println("異步任務(wù)1結(jié)束");
returnresult;
},executorService);

//開(kāi)啟異步任務(wù)2
CompletableFuturetask2=CompletableFuture.supplyAsync(()->{
System.out.println("異步任務(wù)2，當(dāng)前線(xiàn)程是："+Thread.currentThread().getId());
intresult=1+2;
try{
Thread.sleep(3000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println("異步任務(wù)2結(jié)束");
returnresult;
},executorService);

//任務(wù)組合
task.acceptEitherAsync(task2,(res)->{
System.out.println("執(zhí)行任務(wù)3，當(dāng)前線(xiàn)程是："+Thread.currentThread().getId());
System.out.println("上一個(gè)任務(wù)的結(jié)果為："+res);
},executorService);
}

運(yùn)行結(jié)果

//通過(guò)結(jié)果可以看出，異步任務(wù)2都沒(méi)有執(zhí)行結(jié)束，任務(wù)3獲取的也是1的執(zhí)行結(jié)果
異步任務(wù)1，當(dāng)前線(xiàn)程是：17
異步任務(wù)1結(jié)束
異步任務(wù)2，當(dāng)前線(xiàn)程是：18
執(zhí)行任務(wù)3，當(dāng)前線(xiàn)程是：19
上一個(gè)任務(wù)的結(jié)果為：2

注意

如果把上面的核心線(xiàn)程數(shù)改為1也就是

ExecutorServiceexecutorService=Executors.newFixedThreadPool(1);

運(yùn)行結(jié)果就是下面的了，會(huì)發(fā)現(xiàn)根本沒(méi)有執(zhí)行任務(wù)3，顯然是任務(wù)3直接被丟棄了。

異步任務(wù)1，當(dāng)前線(xiàn)程是：17
異步任務(wù)1結(jié)束
異步任務(wù)2，當(dāng)前線(xiàn)程是：17

3、多任務(wù)組合

• 「allOf」 ：等待所有任務(wù)完成
• 「anyOf」 ：只要有一個(gè)任務(wù)完成

示例

allOf：等待所有任務(wù)完成

@Test
publicvoidtestCompletableAallOf()throwsExecutionException,InterruptedException{
//創(chuàng)建線(xiàn)程池
ExecutorServiceexecutorService=Executors.newFixedThreadPool(10);
//開(kāi)啟異步任務(wù)1
CompletableFuturetask=CompletableFuture.supplyAsync(()->{
System.out.println("異步任務(wù)1，當(dāng)前線(xiàn)程是："+Thread.currentThread().getId());
intresult=1+1;
System.out.println("異步任務(wù)1結(jié)束");
returnresult;
},executorService);

//開(kāi)啟異步任務(wù)2
CompletableFuturetask2=CompletableFuture.supplyAsync(()->{
System.out.println("異步任務(wù)2，當(dāng)前線(xiàn)程是："+Thread.currentThread().getId());
intresult=1+2;
try{
Thread.sleep(3000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println("異步任務(wù)2結(jié)束");
returnresult;
},executorService);

//開(kāi)啟異步任務(wù)3
CompletableFuturetask3=CompletableFuture.supplyAsync(()->{
System.out.println("異步任務(wù)3，當(dāng)前線(xiàn)程是："+Thread.currentThread().getId());
intresult=1+3;
try{
Thread.sleep(4000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println("異步任務(wù)3結(jié)束");
returnresult;
},executorService);

//任務(wù)組合
CompletableFutureallOf=CompletableFuture.allOf(task,task2,task3);

//等待所有任務(wù)完成
allOf.get();
//獲取任務(wù)的返回結(jié)果
System.out.println("task結(jié)果為："+task.get());
System.out.println("task2結(jié)果為："+task2.get());
System.out.println("task3結(jié)果為："+task3.get());
}

anyOf: 只要有一個(gè)任務(wù)完成

@Test
publicvoidtestCompletableAnyOf()throwsExecutionException,InterruptedException{
//創(chuàng)建線(xiàn)程池
ExecutorServiceexecutorService=Executors.newFixedThreadPool(10);
//開(kāi)啟異步任務(wù)1
CompletableFuturetask=CompletableFuture.supplyAsync(()->{
intresult=1+1;
returnresult;
},executorService);

//開(kāi)啟異步任務(wù)2
CompletableFuturetask2=CompletableFuture.supplyAsync(()->{
intresult=1+2;
returnresult;
},executorService);

//開(kāi)啟異步任務(wù)3
CompletableFuturetask3=CompletableFuture.supplyAsync(()->{
intresult=1+3;
returnresult;
},executorService);

//任務(wù)組合
CompletableFuture