CompletableFuture異步多線程是真的優(yōu)雅

下面來看看示例

1、只用whenComplete

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

if(Math.random()0.5){
thrownewRuntimeException("出錯了");
}
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());
}

正常完成，沒有異常時：

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

出現(xiàn)異常時：get()會拋出異常

whenCompleteaDoubleisnull
whenCompletethrowableisjava.lang.RuntimeException:出錯了

java.util.concurrent.ExecutionException:java.lang.RuntimeException:出錯了
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("出錯了");
}
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)異常時，exceptionally中會捕獲該異常，給出默認(rèn)返回值0.0。

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

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

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

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

區(qū)別在于：

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

示例

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

//開啟異步任務(wù)2
CompletableFuturetask2=CompletableFuture.supplyAsync(()->{
System.out.println("異步任務(wù)2，當(dāng)前線程是："+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)前線程是："+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)前線程是：17
異步任務(wù)1結(jié)束
異步任務(wù)2，當(dāng)前線程是：18
異步任務(wù)2結(jié)束
執(zhí)行任務(wù)3，當(dāng)前線程是：19
任務(wù)1返回值：2
任務(wù)2返回值：2
最終結(jié)果：4

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

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

區(qū)別在于：

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

示例

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

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

//開啟異步任務(wù)2
CompletableFuturetask2=CompletableFuture.supplyAsync(()->{
System.out.println("異步任務(wù)2，當(dāng)前線程是："+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)前線程是："+Thread.currentThread().getId());
System.out.println("上一個任務(wù)的結(jié)果為："+res);
},executorService);
}

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

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

注意

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

ExecutorServiceexecutorService=Executors.newFixedThreadPool(1);

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

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

3、多任務(wù)組合

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

示例

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

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

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

//開啟異步任務(wù)3
CompletableFuturetask3=CompletableFuture.supplyAsync(()->{
System.out.println("異步任務(wù)3，當(dāng)前線程是："+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: 只要有一個任務(wù)完成

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

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

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

//任務(wù)組合
CompletableFuture