Java中的CompletableFuture使用解析
CompletableFuture常用方法
- CompletableFuture的join方法可以直接拿到返回值
- supplyAsync,開啟異步任務
- thenCompose,接收前面的返回值,前面執(zhí)行完了再執(zhí)行后面的
- thenCombine,兩個任務一起執(zhí)行
- thenApply,把前面異步執(zhí)行的結果,交給后面的異步任務,同一個線程
- thenApplyAsync,把前面的幾個結果交給后面的異步任務,不同線程 和thenCompose 比較像
- applyToEither,要么,上個任務和這個任務一起運行,哪個任務先執(zhí)行完,先返回哪個任務
- exceptionally,如果多個任務有一個出現(xiàn)異常,就會執(zhí)行,這里的代碼
- Stream表達式并行執(zhí)行多任務

為什么CompletableFuture要定制化線程池,因為默認的線程池是ForkJoinPool,這個線程池的最大線程數默認是你的電腦的線程數數減1,假如我線程電腦是4核8線程的,F(xiàn)orkJoinPool的最大線程數就是7。
現(xiàn)在很多的電腦都是1個CPU2個線程,類似6核12線程,但是實際上某些任務場景下,可能還是只有6個線程執(zhí)行,假如是這種任務,當我的任務數量大于7的時候,這個時候一波線程執(zhí)行不完,部分線程需要執(zhí)行2遍(實際上由于存在cpu的時間片機制,第7個任務會分配到其他各個cpu上執(zhí)行,所以時間也不會突然暴增到2倍,這個時間增長是線性的)。
所以我們在自定義業(yè)務線程池的時候,也沒有必要制定的很高。
// 查看處理器數量,4核8線程 System.out.println(Runtime.getRuntime().availableProcessors());
阻塞隊列BlockingQueue
- 有容量大小
- 隊列滿了放不進去,put的時候會阻塞
- 隊列空了取不出來,take取出的時候會阻塞
到此這篇關于Java中的CompletableFuture使用解析的文章就介紹到這了,更多相關CompletableFuture使用內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
Springboot上傳excel并將表格數據導入或更新mySql數據庫的過程
這篇文章主要介紹了Springboot上傳excel并將表格數據導入或更新mySql數據庫的過程 ,本文以Controller開始,從導入過程開始講述,其中包括字典表的轉換,需要的朋友可以參考下2018-04-04
使用XSD校驗Mybatis的SqlMapper配置文件的方法(2)
這篇文章主要介紹了使用XSD校驗Mybatis的SqlMapper配置文件的方法(2)的相關資料,非常不錯具有參考借鑒價值,需要的朋友可以參考下2016-11-11

