CompletableFuture常用方法

• CompletableFuture的join方法可以直接拿到返回值
• supplyAsync，開(kāi)啟異步任務(wù)
• thenCompose，接收前面的返回值，前面執(zhí)行完了再執(zhí)行后面的
• thenCombine，兩個(gè)任務(wù)一起執(zhí)行
• thenApply，把前面異步執(zhí)行的結(jié)果，交給后面的異步任務(wù)，同一個(gè)線程
• thenApplyAsync，把前面的幾個(gè)結(jié)果交給后面的異步任務(wù)，不同線程 和thenCompose 比較像
• applyToEither，要么，上個(gè)任務(wù)和這個(gè)任務(wù)一起運(yùn)行，哪個(gè)任務(wù)先執(zhí)行完，先返回哪個(gè)任務(wù)
• exceptionally，如果多個(gè)任務(wù)有一個(gè)出現(xiàn)異常，就會(huì)執(zhí)行，這里的代碼
• Stream表達(dá)式并行執(zhí)行多任務(wù)

為什么CompletableFuture要定制化線程池，因?yàn)槟J(rèn)的線程池是ForkJoinPool，這個(gè)線程池的最大線程數(shù)默認(rèn)是你的電腦的線程數(shù)數(shù)減1，假如我線程電腦是4核8線程的，F(xiàn)orkJoinPool的最大線程數(shù)就是7。

現(xiàn)在很多的電腦都是1個(gè)CPU2個(gè)線程，類(lèi)似6核12線程，但是實(shí)際上某些任務(wù)場(chǎng)景下，可能還是只有6個(gè)線程執(zhí)行，假如是這種任務(wù)，當(dāng)我的任務(wù)數(shù)量大于7的時(shí)候，這個(gè)時(shí)候一波線程執(zhí)行不完，部分線程需要執(zhí)行2遍（實(shí)際上由于存在cpu的時(shí)間片機(jī)制，第7個(gè)任務(wù)會(huì)分配到其他各個(gè)cpu上執(zhí)行，所以時(shí)間也不會(huì)突然暴增到2倍，這個(gè)時(shí)間增長(zhǎng)是線性的）。

所以我們?cè)谧远x業(yè)務(wù)線程池的時(shí)候，也沒(méi)有必要制定的很高。

// 查看處理器數(shù)量，4核8線程
System.out.println(Runtime.getRuntime().availableProcessors());

阻塞隊(duì)列BlockingQueue

• 有容量大小
• 隊(duì)列滿了放不進(jìn)去，put的時(shí)候會(huì)阻塞
• 隊(duì)列空了取不出來(lái)，take取出的時(shí)候會(huì)阻塞

到此這篇關(guān)于Java中的CompletableFuture使用解析的文章就介紹到這了,更多相關(guān)CompletableFuture使用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！