女人自慰AV免费观看内涵网,日韩国产剧情在线观看网址,神马电影网特片网,最新一级电影欧美,在线观看亚洲欧美日韩,黄色视频在线播放免费观看,ABO涨奶期羡澄,第一导航fulione,美女主播操b

0
  • 聊天消息
  • 系統(tǒng)消息
  • 評(píng)論與回復(fù)
登錄后你可以
  • 下載海量資料
  • 學(xué)習(xí)在線課程
  • 觀看技術(shù)視頻
  • 寫文章/發(fā)帖/加入社區(qū)
會(huì)員中心
創(chuàng)作中心

完善資料讓更多小伙伴認(rèn)識(shí)你,還能領(lǐng)取20積分哦,立即完善>

3天內(nèi)不再提示

異步神器CompletableFuture萬字詳解!

jf_ro2CN3Fa ? 來源:CSDN ? 作者:CSDN ? 2022-11-15 10:15 ? 次閱讀
加入交流群
微信小助手二維碼

掃碼添加小助手

加入工程師交流群


CompletableFuture是jdk8的新特性。CompletableFuture實(shí)現(xiàn)了CompletionStage接口和Future接口,前者是對(duì)后者的一個(gè)擴(kuò)展,增加了異步會(huì)點(diǎn)、流式處理、多個(gè)Future組合處理的能力,使Java在處理多任務(wù)的協(xié)同工作時(shí)更加順暢便利。

一、創(chuàng)建異步任務(wù)

1. supplyAsync

supplyAsync是創(chuàng)建帶有返回值的異步任務(wù)。它有如下兩個(gè)方法,一個(gè)是使用默認(rèn)線程池(ForkJoinPool.commonPool())的方法,一個(gè)是帶有自定義線程池的重載方法

//帶返回值異步請(qǐng)求,默認(rèn)線程池
publicstaticCompletableFuturesupplyAsync(Suppliersupplier)

//帶返回值的異步請(qǐng)求,可以自定義線程池
publicstaticCompletableFuturesupplyAsync(Suppliersupplier,Executorexecutor)

測(cè)試代碼:

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf=CompletableFuture.supplyAsync(()->{
System.out.println("dosomething....");
return"result";
});

//等待任務(wù)執(zhí)行完成
System.out.println("結(jié)果->"+cf.get());
}


publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
//自定義線程池
ExecutorServiceexecutorService=Executors.newSingleThreadExecutor();
CompletableFuturecf=CompletableFuture.supplyAsync(()->{
System.out.println("dosomething....");
return"result";
},executorService);

//等待子任務(wù)執(zhí)行完成
System.out.println("結(jié)果->"+cf.get());
}

測(cè)試結(jié)果:

90bc4a4e-648a-11ed-8abf-dac502259ad0.png

2. runAsync

runAsync是創(chuàng)建沒有返回值的異步任務(wù)。它有如下兩個(gè)方法,一個(gè)是使用默認(rèn)線程池(ForkJoinPool.commonPool())的方法,一個(gè)是帶有自定義線程池的重載方法

//不帶返回值的異步請(qǐng)求,默認(rèn)線程池
publicstaticCompletableFuturerunAsync(Runnablerunnable)

//不帶返回值的異步請(qǐng)求,可以自定義線程池
publicstaticCompletableFuturerunAsync(Runnablerunnable,Executorexecutor)

測(cè)試代碼:

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf=CompletableFuture.runAsync(()->{
System.out.println("dosomething....");
});

//等待任務(wù)執(zhí)行完成
System.out.println("結(jié)果->"+cf.get());
}


publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
//自定義線程池
ExecutorServiceexecutorService=Executors.newSingleThreadExecutor();
CompletableFuturecf=CompletableFuture.runAsync(()->{
System.out.println("dosomething....");
},executorService);

//等待任務(wù)執(zhí)行完成
System.out.println("結(jié)果->"+cf.get());
}

測(cè)試結(jié)果:

90e0da4e-648a-11ed-8abf-dac502259ad0.png

3.獲取任務(wù)結(jié)果的方法

//如果完成則返回結(jié)果,否則就拋出具體的異常
publicTget()throwsInterruptedException,ExecutionException

//最大時(shí)間等待返回結(jié)果,否則就拋出具體異常
publicTget(longtimeout,TimeUnitunit)throwsInterruptedException,ExecutionException,TimeoutException

//完成時(shí)返回結(jié)果值,否則拋出unchecked異常。為了更好地符合通用函數(shù)形式的使用,如果完成此CompletableFuture所涉及的計(jì)算引發(fā)異常,則此方法將引發(fā)unchecked異常并將底層異常作為其原因
publicTjoin()

//如果完成則返回結(jié)果值(或拋出任何遇到的異常),否則返回給定的valueIfAbsent。
publicTgetNow(TvalueIfAbsent)

//如果任務(wù)沒有完成,返回的值設(shè)置為給定值
publicbooleancomplete(Tvalue)

//如果任務(wù)沒有完成,就拋出給定異常
publicbooleancompleteExceptionally(Throwableex)

基于 Spring Boot + MyBatis Plus + Vue & Element 實(shí)現(xiàn)的后臺(tái)管理系統(tǒng) + 用戶小程序,支持 RBAC 動(dòng)態(tài)權(quán)限、多租戶、數(shù)據(jù)權(quán)限、工作流、三方登錄、支付、短信、商城等功能

  • 項(xiàng)目地址:https://github.com/YunaiV/ruoyi-vue-pro
  • 視頻教程:https://doc.iocoder.cn/video/

二、異步回調(diào)處理

1. thenApply和thenApplyAsync

thenApply 表示某個(gè)任務(wù)執(zhí)行完成后執(zhí)行的動(dòng)作,即回調(diào)方法,會(huì)將該任務(wù)的執(zhí)行結(jié)果即方法返回值作為入?yún)鬟f到回調(diào)方法中,帶有返回值。

測(cè)試代碼:

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf1dosomething....");
return1;
});

CompletableFuturecf2=cf1.thenApplyAsync((result)->{
System.out.println(Thread.currentThread()+"cf2dosomething....");
result+=2;
returnresult;
});
//等待任務(wù)1執(zhí)行完成
System.out.println("cf1結(jié)果->"+cf1.get());
//等待任務(wù)2執(zhí)行完成
System.out.println("cf2結(jié)果->"+cf2.get());
}

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf1dosomething....");
return1;
});

CompletableFuturecf2=cf1.thenApply((result)->{
System.out.println(Thread.currentThread()+"cf2dosomething....");
result+=2;
returnresult;
});
//等待任務(wù)1執(zhí)行完成
System.out.println("cf1結(jié)果->"+cf1.get());
//等待任務(wù)2執(zhí)行完成
System.out.println("cf2結(jié)果->"+cf2.get());
}

測(cè)試結(jié)果:

9114db50-648a-11ed-8abf-dac502259ad0.png 914c3bd6-648a-11ed-8abf-dac502259ad0.png

從上面代碼和測(cè)試結(jié)果我們發(fā)現(xiàn)thenApply和thenApplyAsync區(qū)別在于,使用thenApply方法時(shí)子任務(wù)與父任務(wù)使用的是同一個(gè)線程,而thenApplyAsync在子任務(wù)中是另起一個(gè)線程執(zhí)行任務(wù),并且thenApplyAsync可以自定義線程池,默認(rèn)的使用ForkJoinPool.commonPool()線程池。

2. thenAccept和thenAcceptAsync

thenAccep表示某個(gè)任務(wù)執(zhí)行完成后執(zhí)行的動(dòng)作,即回調(diào)方法,會(huì)將該任務(wù)的執(zhí)行結(jié)果即方法返回值作為入?yún)鬟f到回調(diào)方法中,無返回值。

測(cè)試代碼

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf1dosomething....");
return1;
});

CompletableFuturecf2=cf1.thenAccept((result)->{
System.out.println(Thread.currentThread()+"cf2dosomething....");
});

//等待任務(wù)1執(zhí)行完成
System.out.println("cf1結(jié)果->"+cf1.get());
//等待任務(wù)2執(zhí)行完成
System.out.println("cf2結(jié)果->"+cf2.get());
}


publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf1dosomething....");
return1;
});

CompletableFuturecf2=cf1.thenAcceptAsync((result)->{
System.out.println(Thread.currentThread()+"cf2dosomething....");
});

//等待任務(wù)1執(zhí)行完成
System.out.println("cf1結(jié)果->"+cf1.get());
//等待任務(wù)2執(zhí)行完成
System.out.println("cf2結(jié)果->"+cf2.get());
}

測(cè)試結(jié)果:

915c4ad0-648a-11ed-8abf-dac502259ad0.png 917f8ce8-648a-11ed-8abf-dac502259ad0.png從上面代碼和測(cè)試結(jié)果我們發(fā)現(xiàn)thenAccep和thenAccepAsync區(qū)別在于,使用thenAccep方法時(shí)子任務(wù)與父任務(wù)使用的是同一個(gè)線程,而thenAccepAsync在子任務(wù)中可能是另起一個(gè)線程執(zhí)行任務(wù),并且thenAccepAsync可以自定義線程池,默認(rèn)的使用ForkJoinPool.commonPool()線程池。

3.thenRun和thenRunAsync

thenRun表示某個(gè)任務(wù)執(zhí)行完成后執(zhí)行的動(dòng)作,即回調(diào)方法,無入?yún)ⅲ瑹o返回值。

測(cè)試代碼:

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf1dosomething....");
return1;
});

CompletableFuturecf2=cf1.thenRun(()->{
System.out.println(Thread.currentThread()+"cf2dosomething....");
});

//等待任務(wù)1執(zhí)行完成
System.out.println("cf1結(jié)果->"+cf1.get());
//等待任務(wù)2執(zhí)行完成
System.out.println("cf2結(jié)果->"+cf2.get());
}

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf1dosomething....");
return1;
});

CompletableFuturecf2=cf1.thenRunAsync(()->{
System.out.println(Thread.currentThread()+"cf2dosomething....");
});

//等待任務(wù)1執(zhí)行完成
System.out.println("cf1結(jié)果->"+cf1.get());
//等待任務(wù)2執(zhí)行完成
System.out.println("cf2結(jié)果->"+cf2.get());
}

測(cè)試結(jié)果:

919bd614-648a-11ed-8abf-dac502259ad0.png91aa1882-648a-11ed-8abf-dac502259ad0.png

從上面代碼和測(cè)試結(jié)果我們發(fā)現(xiàn)thenRun和thenRunAsync區(qū)別在于,使用thenRun方法時(shí)子任務(wù)與父任務(wù)使用的是同一個(gè)線程,而thenRunAsync在子任務(wù)中可能是另起一個(gè)線程執(zhí)行任務(wù),并且thenRunAsync可以自定義線程池,默認(rèn)的使用ForkJoinPool.commonPool()線程池。

4.whenComplete和whenCompleteAsync

whenComplete是當(dāng)某個(gè)任務(wù)執(zhí)行完成后執(zhí)行的回調(diào)方法,會(huì)將執(zhí)行結(jié)果或者執(zhí)行期間拋出的異常傳遞給回調(diào)方法,如果是正常執(zhí)行則異常為null,回調(diào)方法對(duì)應(yīng)的CompletableFuture的result和該任務(wù)一致,如果該任務(wù)正常執(zhí)行,則get方法返回執(zhí)行結(jié)果,如果是執(zhí)行異常,則get方法拋出異常。

測(cè)試代碼:

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf1dosomething....");
inta=1/0;
return1;
});

CompletableFuturecf2=cf1.whenComplete((result,e)->{
System.out.println("上個(gè)任務(wù)結(jié)果:"+result);
System.out.println("上個(gè)任務(wù)拋出異常:"+e);
System.out.println(Thread.currentThread()+"cf2dosomething....");
});

////等待任務(wù)1執(zhí)行完成
//System.out.println("cf1結(jié)果->"+cf1.get());
////等待任務(wù)2執(zhí)行完成
System.out.println("cf2結(jié)果->"+cf2.get());
}

測(cè)試結(jié)果:

91b85c44-648a-11ed-8abf-dac502259ad0.png

whenCompleteAsync和whenComplete區(qū)別也是whenCompleteAsync可能會(huì)另起一個(gè)線程執(zhí)行任務(wù),并且thenRunAsync可以自定義線程池,默認(rèn)的使用ForkJoinPool.commonPool()線程池。

5.handle和handleAsync

跟whenComplete基本一致,區(qū)別在于handle的回調(diào)方法有返回值。

測(cè)試代碼:

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf1dosomething....");
//inta=1/0;
return1;
});

CompletableFuturecf2=cf1.handle((result,e)->{
System.out.println(Thread.currentThread()+"cf2dosomething....");
System.out.println("上個(gè)任務(wù)結(jié)果:"+result);
System.out.println("上個(gè)任務(wù)拋出異常:"+e);
returnresult+2;
});

//等待任務(wù)2執(zhí)行完成
System.out.println("cf2結(jié)果->"+cf2.get());
}

測(cè)試結(jié)果 :

91dba032-648a-11ed-8abf-dac502259ad0.png

基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 實(shí)現(xiàn)的后臺(tái)管理系統(tǒng) + 用戶小程序,支持 RBAC 動(dòng)態(tài)權(quán)限、多租戶、數(shù)據(jù)權(quán)限、工作流、三方登錄、支付、短信、商城等功能

  • 項(xiàng)目地址:https://github.com/YunaiV/yudao-cloud
  • 視頻教程:https://doc.iocoder.cn/video/

三、多任務(wù)組合處理

1. thenCombine、thenAcceptBoth 和runAfterBoth

這三個(gè)方法都是將兩個(gè)CompletableFuture組合起來處理,只有兩個(gè)任務(wù)都正常完成時(shí),才進(jìn)行下階段任務(wù)。

區(qū)別:thenCombine會(huì)將兩個(gè)任務(wù)的執(zhí)行結(jié)果作為所提供函數(shù)的參數(shù),且該方法有返回值;thenAcceptBoth同樣將兩個(gè)任務(wù)的執(zhí)行結(jié)果作為方法入?yún)ⅲ菬o返回值;runAfterBoth沒有入?yún)ⅲ矝]有返回值。注意兩個(gè)任務(wù)中只要有一個(gè)執(zhí)行異常,則將該異常信息作為指定任務(wù)的執(zhí)行結(jié)果。

測(cè)試代碼:

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf1dosomething....");
return1;
});

CompletableFuturecf2=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf2dosomething....");
return2;
});

CompletableFuturecf3=cf1.thenCombine(cf2,(a,b)->{
System.out.println(Thread.currentThread()+"cf3dosomething....");
returna+b;
});

System.out.println("cf3結(jié)果->"+cf3.get());
}

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf1dosomething....");
return1;
});

CompletableFuturecf2=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf2dosomething....");
return2;
});

CompletableFuturecf3=cf1.thenAcceptBoth(cf2,(a,b)->{
System.out.println(Thread.currentThread()+"cf3dosomething....");
System.out.println(a+b);
});

System.out.println("cf3結(jié)果->"+cf3.get());
}

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf1dosomething....");
return1;
});

CompletableFuturecf2=CompletableFuture.supplyAsync(()->{
System.out.println(Thread.currentThread()+"cf2dosomething....");
return2;
});

CompletableFuturecf3=cf1.runAfterBoth(cf2,()->{
System.out.println(Thread.currentThread()+"cf3dosomething....");
});

System.out.println("cf3結(jié)果->"+cf3.get());
}

測(cè)試結(jié)果:

91f51922-648a-11ed-8abf-dac502259ad0.png9211a330-648a-11ed-8abf-dac502259ad0.png

92274e9c-648a-11ed-8abf-dac502259ad0.png 2.applyToEither、acceptEither和runAfterEither

這三個(gè)方法和上面一樣也是將兩個(gè)CompletableFuture組合起來處理,當(dāng)有一個(gè)任務(wù)正常完成時(shí),就會(huì)進(jìn)行下階段任務(wù)。

區(qū)別:applyToEither會(huì)將已經(jīng)完成任務(wù)的執(zhí)行結(jié)果作為所提供函數(shù)的參數(shù),且該方法有返回值;acceptEither同樣將已經(jīng)完成任務(wù)的執(zhí)行結(jié)果作為方法入?yún)ⅲ菬o返回值;runAfterEither沒有入?yún)ⅲ矝]有返回值。

測(cè)試代碼:

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
try{
System.out.println(Thread.currentThread()+"cf1dosomething....");
Thread.sleep(2000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
return"cf1任務(wù)完成";
});

CompletableFuturecf2=CompletableFuture.supplyAsync(()->{
try{
System.out.println(Thread.currentThread()+"cf2dosomething....");
Thread.sleep(5000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
return"cf2任務(wù)完成";
});

CompletableFuturecf3=cf1.applyToEither(cf2,(result)->{
System.out.println("接收到"+result);
System.out.println(Thread.currentThread()+"cf3dosomething....");
return"cf3任務(wù)完成";
});

System.out.println("cf3結(jié)果->"+cf3.get());
}


publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
try{
System.out.println(Thread.currentThread()+"cf1dosomething....");
Thread.sleep(2000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
return"cf1任務(wù)完成";
});

CompletableFuturecf2=CompletableFuture.supplyAsync(()->{
try{
System.out.println(Thread.currentThread()+"cf2dosomething....");
Thread.sleep(5000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
return"cf2任務(wù)完成";
});

CompletableFuturecf3=cf1.acceptEither(cf2,(result)->{
System.out.println("接收到"+result);
System.out.println(Thread.currentThread()+"cf3dosomething....");
});

System.out.println("cf3結(jié)果->"+cf3.get());
}

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
try{
System.out.println(Thread.currentThread()+"cf1dosomething....");
Thread.sleep(2000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println("cf1任務(wù)完成");
return"cf1任務(wù)完成";
});

CompletableFuturecf2=CompletableFuture.supplyAsync(()->{
try{
System.out.println(Thread.currentThread()+"cf2dosomething....");
Thread.sleep(5000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println("cf2任務(wù)完成");
return"cf2任務(wù)完成";
});

CompletableFuturecf3=cf1.runAfterEither(cf2,()->{
System.out.println(Thread.currentThread()+"cf3dosomething....");
System.out.println("cf3任務(wù)完成");
});

System.out.println("cf3結(jié)果->"+cf3.get());
}

測(cè)試結(jié)果:

92418438-648a-11ed-8abf-dac502259ad0.png925d7cc4-648a-11ed-8abf-dac502259ad0.png

從上面可以看出cf1任務(wù)完成需要2秒,cf2任務(wù)完成需要5秒,使用applyToEither組合兩個(gè)任務(wù)時(shí),只要有其中一個(gè)任務(wù)完成時(shí),就會(huì)執(zhí)行cf3任務(wù),顯然cf1任務(wù)先完成了并且將自己任務(wù)的結(jié)果傳值給了cf3任務(wù),cf3任務(wù)中打印了接收到cf1任務(wù)完成,接著完成自己的任務(wù),并返回cf3任務(wù)完成;acceptEither和runAfterEither類似,acceptEither會(huì)將cf1任務(wù)的結(jié)果作為cf3任務(wù)的入?yún)ⅲ玞f3任務(wù)完成時(shí)并無返回值;runAfterEither不會(huì)將cf1任務(wù)的結(jié)果作為cf3任務(wù)的入?yún)ⅲ菦]有任務(wù)入?yún)ⅲ瑘?zhí)行完自己的任務(wù)后也并無返回值。

2. allOf / anyOf

allOf:CompletableFuture是多個(gè)任務(wù)都執(zhí)行完成后才會(huì)執(zhí)行,只有有一個(gè)任務(wù)執(zhí)行異常,則返回的CompletableFuture執(zhí)行g(shù)et方法時(shí)會(huì)拋出異常,如果都是正常執(zhí)行,則get返回null。

anyOf :CompletableFuture是多個(gè)任務(wù)只要有一個(gè)任務(wù)執(zhí)行完成,則返回的CompletableFuture執(zhí)行g(shù)et方法時(shí)會(huì)拋出異常,如果都是正常執(zhí)行,則get返回執(zhí)行完成任務(wù)的結(jié)果。

測(cè)試代碼:

publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
try{
System.out.println(Thread.currentThread()+"cf1dosomething....");
Thread.sleep(2000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println("cf1任務(wù)完成");
return"cf1任務(wù)完成";
});

CompletableFuturecf2=CompletableFuture.supplyAsync(()->{
try{
System.out.println(Thread.currentThread()+"cf2dosomething....");
inta=1/0;
Thread.sleep(5000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println("cf2任務(wù)完成");
return"cf2任務(wù)完成";
});

CompletableFuturecf3=CompletableFuture.supplyAsync(()->{
try{
System.out.println(Thread.currentThread()+"cf2dosomething....");
Thread.sleep(3000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println("cf3任務(wù)完成");
return"cf3任務(wù)完成";
});

CompletableFuturecfAll=CompletableFuture.allOf(cf1,cf2,cf3);
System.out.println("cfAll結(jié)果->"+cfAll.get());
}


publicstaticvoidmain(String[]args)throwsExecutionException,InterruptedException{
CompletableFuturecf1=CompletableFuture.supplyAsync(()->{
try{
System.out.println(Thread.currentThread()+"cf1dosomething....");
Thread.sleep(2000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println("cf1任務(wù)完成");
return"cf1任務(wù)完成";
});

CompletableFuturecf2=CompletableFuture.supplyAsync(()->{
try{
System.out.println(Thread.currentThread()+"cf2dosomething....");
Thread.sleep(5000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println("cf2任務(wù)完成");
return"cf2任務(wù)完成";
});

CompletableFuturecf3=CompletableFuture.supplyAsync(()->{
try{
System.out.println(Thread.currentThread()+"cf2dosomething....");
Thread.sleep(3000);
}catch(InterruptedExceptione){
e.printStackTrace();
}
System.out.println("cf3任務(wù)完成");
return"cf3任務(wù)完成";
});

CompletableFuturecfAll=CompletableFuture.anyOf(cf1,cf2,cf3);
System.out.println("cfAll結(jié)果->"+cfAll.get());
}

		

測(cè)試結(jié)果:

9278b9a8-648a-11ed-8abf-dac502259ad0.png928fa848-648a-11ed-8abf-dac502259ad0.png

審核編輯 :李倩


聲明:本文內(nèi)容及配圖由入駐作者撰寫或者入駐合作網(wǎng)站授權(quán)轉(zhuǎn)載。文章觀點(diǎn)僅代表作者本人,不代表電子發(fā)燒友網(wǎng)立場(chǎng)。文章及其配圖僅供工程師學(xué)習(xí)之用,如有內(nèi)容侵權(quán)或者其他違規(guī)問題,請(qǐng)聯(lián)系本站處理。 舉報(bào)投訴
  • 接口
    +關(guān)注

    關(guān)注

    33

    文章

    8975

    瀏覽量

    153518
  • 線程
    +關(guān)注

    關(guān)注

    0

    文章

    508

    瀏覽量

    20151

原文標(biāo)題:一網(wǎng)打盡:異步神器 CompletableFuture 萬字詳解!

文章出處:【微信號(hào):芋道源碼,微信公眾號(hào):芋道源碼】歡迎添加關(guān)注!文章轉(zhuǎn)載請(qǐng)注明出處。

收藏 人收藏
加入交流群
微信小助手二維碼

掃碼添加小助手

加入工程師交流群

    評(píng)論

    相關(guān)推薦
    熱點(diǎn)推薦

    萬字長文】物聯(lián)網(wǎng)的激蕩二十年

    2005年11月,在突尼斯舉辦的信息社會(huì)世界峰會(huì)(WSIS)上,國際電信聯(lián)盟(ITU)發(fā)布了一份名為《ITU互聯(lián)網(wǎng)報(bào)告2005:物聯(lián)網(wǎng)》,正式向世人展示了什么是“物聯(lián)網(wǎng)(InternetofThings)”。雖然業(yè)界一致認(rèn)為,1999年,麻省理工學(xué)院的KevinAshton首次提出”物聯(lián)網(wǎng)”這一術(shù)語,但僅僅只是一個(gè)理念,沒有成體系的解釋,也無法形成共識(shí)。而I
    的頭像 發(fā)表于 06-27 13:42 ?422次閱讀
    【<b class='flag-5'>萬字</b>長文】物聯(lián)網(wǎng)的激蕩二十年

    (ST大賽三等獎(jiǎng)作品)超聲波自拍神器實(shí)例項(xiàng)目

    (ST大賽三等獎(jiǎng)作品)超聲波自拍神器電路圖:
    發(fā)表于 05-28 21:04

    全面解析新概念模擬電路(建議下載!)

    全文共五冊(cè),近50萬字,一樣的風(fēng)趣幽默,一樣的social化語言,深入淺出地將枯燥深?yuàn)W的模電知識(shí)講得簡(jiǎn)單易學(xué)。 《新概念模擬電路》內(nèi)容包含了《晶體管》、《負(fù)反饋和運(yùn)算放大器》、《運(yùn)放電路的頻率特性
    發(fā)表于 04-16 13:37

    萬字聊聊什么是智能車載終端?為什么智駕發(fā)展離不開它?

    智能車載終端作為車聯(lián)網(wǎng)技術(shù)的核心,近年來發(fā)展迅速,已成為汽車智能化和自動(dòng)駕駛領(lǐng)域的關(guān)鍵支撐技術(shù)。其核心功能涵蓋智能導(dǎo)航、實(shí)時(shí)通信、娛樂互動(dòng)、安全監(jiān)控等,為駕駛者和乘客提供全面的服務(wù)支持。隨著自動(dòng)駕駛和智能網(wǎng)聯(lián)汽車的發(fā)展需求不斷增長,智能車載終端的市場(chǎng)規(guī)模快速擴(kuò)展,同時(shí)也面臨技術(shù)創(chuàng)新、市場(chǎng)競(jìng)爭(zhēng)、產(chǎn)業(yè)鏈協(xié)同及政策規(guī)范等多重挑戰(zhàn)。 ? 引言 智能車載終端作為汽車智能化發(fā)展的核心技術(shù)之一,其重要性日益凸顯。在汽
    的頭像 發(fā)表于 03-31 09:12 ?4364次閱讀
    <b class='flag-5'>萬字</b>聊聊什么是智能車載終端?為什么智駕發(fā)展離不開它?

    投資筆記:3萬字詳解100大新材料國產(chǎn)替代(附100+行研報(bào)告)

    新材料/半導(dǎo)體/新能源/光伏/顯示材料等正文半導(dǎo)體晶圓制造材料(11種)先進(jìn)封裝材料(12種)半導(dǎo)體零部件材料(3種)顯示材料(11種)高性能纖維(12種)工程塑料(13種)高性能膜材(6種)先進(jìn)陶瓷材料(9種)高性能合金(4種)一、半導(dǎo)體晶圓制造材料1、
    的頭像 發(fā)表于 02-16 07:54 ?3778次閱讀
    投資筆記:3<b class='flag-5'>萬字</b><b class='flag-5'>詳解</b>100大新材料國產(chǎn)替代(附100+行研報(bào)告)

    Xmind完成對(duì)AI總結(jié)工具Briefy的戰(zhàn)略收購

    全球知名的知識(shí)管理企業(yè)Xmind近日宣布,已完成對(duì)AI總結(jié)工具Briefy的戰(zhàn)略收購。Briefy以其強(qiáng)大的大語言模型驅(qū)動(dòng)的多模態(tài)解析技術(shù)著稱,能夠?qū)㈤L視頻和萬字文檔等復(fù)雜信息轉(zhuǎn)化為結(jié)構(gòu)清晰的大綱或思維導(dǎo)圖,并通過知識(shí)庫功能幫助用戶高效消化和管理知識(shí)。
    的頭像 發(fā)表于 02-13 16:01 ?486次閱讀

    萬字長文!工業(yè)5.0的內(nèi)涵、體系架構(gòu)和使能技術(shù)

    摘要: 工業(yè)4.0誕生以來,強(qiáng)化了數(shù)字化、數(shù)據(jù)驅(qū)動(dòng)和互聯(lián)的工業(yè)所帶來的高度變革性影響。但是工業(yè)4.0沒有強(qiáng)調(diào)工業(yè)在全球范圍內(nèi)為人類提供長期服務(wù)的重要性,也沒有很好解決如何利用技術(shù)創(chuàng)新來促進(jìn)工業(yè)與社會(huì)之間的協(xié)作和“雙贏”互動(dòng)等問題。工業(yè)5.0系統(tǒng)地提出將勞動(dòng)者作為工業(yè)生產(chǎn)的核心,從而實(shí)現(xiàn)就業(yè)和增長之外的社會(huì)目標(biāo),穩(wěn)健地提供繁榮。但是,工業(yè)5.0作為對(duì)工業(yè)未來發(fā)展的再思考,目前其研究尚處于探索階段,研究成果相對(duì)較少且缺乏
    的頭像 發(fā)表于 02-05 11:30 ?1049次閱讀
    <b class='flag-5'>萬字</b>長文!工業(yè)5.0的內(nèi)涵、體系架構(gòu)和使能技術(shù)

    萬字長文,看懂激光基礎(chǔ)知識(shí)!

    深入介紹激光基礎(chǔ)知識(shí),幫助您輕松理解激光領(lǐng)域的關(guān)鍵概念和原理。
    的頭像 發(fā)表于 12-20 09:49 ?1012次閱讀
    <b class='flag-5'>萬字</b>長文,看懂激光基礎(chǔ)知識(shí)!

    套接socket包含哪些參數(shù)

    套接(Socket)是計(jì)算機(jī)網(wǎng)絡(luò)中最基本的通信抽象,它定義了兩個(gè)進(jìn)程間通信的端點(diǎn)。在TCP/IP協(xié)議棧中,套接是實(shí)現(xiàn)網(wǎng)絡(luò)通信的核心組件。 套接的基本概念 套接是一種通信端點(diǎn),它
    的頭像 發(fā)表于 08-16 11:02 ?1031次閱讀

    第三篇-V1.5 TB6612電機(jī)pwm控制STM32智能小車 STM32F103C8T6單片機(jī)

    通過合理的硬件設(shè)計(jì)和詳細(xì)的視頻筆記介紹,硬件使用STM32F103主控資料多方便學(xué)習(xí),通過3萬字筆記、12多個(gè)小時(shí)視頻、20多章節(jié)代碼手把手教會(huì)你如何開發(fā)和調(diào)試。
    的頭像 發(fā)表于 08-12 18:29 ?2723次閱讀
    第三篇-V1.5 TB6612電機(jī)pwm控制STM32智能小車 STM32F103C8T6單片機(jī)

    第一篇:V1.5-STM32f103c8t6智能小車筆記 標(biāo)準(zhǔn)庫開發(fā) 6612電機(jī)驅(qū)動(dòng)新手入門項(xiàng)目

    這是全網(wǎng)最詳細(xì)、性價(jià)比最高的STM32實(shí)戰(zhàn)項(xiàng)目入門教程,通過合理的硬件設(shè)計(jì)和詳細(xì)的視頻筆記介紹,硬件使用STM32F103主控資料多方便學(xué)習(xí),通過3萬字筆記、12多個(gè)小時(shí)視頻、20多章節(jié)代碼手把手教會(huì)你如何開發(fā)和調(diào)試。讓你更快掌握嵌入式系統(tǒng)開發(fā)。
    的頭像 發(fā)表于 08-12 18:25 ?2443次閱讀
    第一篇:V1.5-STM32f103c8t6智能小車筆記 標(biāo)準(zhǔn)庫開發(fā) 6612電機(jī)驅(qū)動(dòng)新手入門項(xiàng)目

    Java CompletableFuture 異步超時(shí)實(shí)現(xiàn)探索

    簡(jiǎn)介 JDK 8 中 CompletableFuture 沒有超時(shí)中斷任務(wù)的能力。現(xiàn)有做法強(qiáng)依賴任務(wù)自身的超時(shí)實(shí)現(xiàn)。本文提出一種異步超時(shí)實(shí)現(xiàn)方案,解決上述問題。 前言 JDK 8 是一次重大的版本
    的頭像 發(fā)表于 07-25 14:06 ?652次閱讀

    FPGA異步信號(hào)處理方法

    FPGA(現(xiàn)場(chǎng)可編程門陣列)在處理異步信號(hào)時(shí),需要特別關(guān)注信號(hào)的同步化、穩(wěn)定性以及潛在的亞穩(wěn)態(tài)問題。由于異步信號(hào)可能來自不同的時(shí)鐘域或外部設(shè)備,其到達(dá)時(shí)間和頻率可能不受FPGA內(nèi)部時(shí)鐘控制,因此處理起來相對(duì)復(fù)雜。以下是對(duì)FPGA異步
    的頭像 發(fā)表于 07-17 11:10 ?1847次閱讀

    快速掌握C語言關(guān)鍵

    C語言中的32個(gè)關(guān)鍵你知道多少個(gè)呢?根據(jù)關(guān)鍵的作用分為四類:數(shù)據(jù)類型關(guān)鍵、控制語句關(guān)鍵、存儲(chǔ)類型關(guān)鍵和其它關(guān)鍵
    的頭像 發(fā)表于 07-06 08:04 ?749次閱讀
    快速掌握C語言關(guān)鍵<b class='flag-5'>字</b>

    1.3萬字詳解半導(dǎo)體先進(jìn)封裝行業(yè),現(xiàn)狀及發(fā)展趨勢(shì)!

    共賞好劇 ? 導(dǎo) 讀?? 在以人工智能、高性能計(jì)算為代表的新需求驅(qū)動(dòng)下,先進(jìn)封裝應(yīng)運(yùn)而生,發(fā)展趨勢(shì)是小型化、高集成度,歷經(jīng)直插型封裝、表面貼裝、面積陣列封裝、2.5D/3D封裝和異構(gòu)集成四個(gè)發(fā)展階段。 典型封裝技術(shù)包括:1)倒片封裝(Flip-Chip):芯片倒置,舍棄金屬引線,利用凸塊連接;2)扇入型/扇出型封裝(Fan-In/Fan-Out):在晶圓上進(jìn)行整體封裝,成本更低,關(guān)鍵工藝為重新布線(RDL);3)2.5D/3D封裝:2.5D封裝中芯片位于硅中介層上,3D封裝舍
    的頭像 發(fā)表于 07-03 08:44 ?3573次閱讀
    1.3<b class='flag-5'>萬字</b>!<b class='flag-5'>詳解</b>半導(dǎo)體先進(jìn)封裝行業(yè),現(xiàn)狀及發(fā)展趨勢(shì)!