基于Java8并行流(parallelStream)的注意點
Java8并行流(parallelStream)注意點
在最初使用并行流的時候,查詢列表會偶爾性報空指針異常,這令我非常納悶
代碼是這樣的:
List<OrderListVO> orderListVOS = new LinkedList<OrderListVO>(); baseOrderBillList.parallelStream().forEach(baseOrderBill -> { OrderListVO orderListVO = new OrderListVO(); // 設置order中的屬性 orderListVO.setOrderbillgrowthid(baseOrderBill.getOrderbillgrowthid()); orderListVO.setOrderbillid(baseOrderBill.getOrderbillid()); …… orderListVOS.add(orderListVO); }
代碼本身是在做多表拆分然后業(yè)務層組裝,使用并行流能夠提升這種純粹的CPU密集型操作,parallelStream 此方法默認是以服務器CPU核數(shù)為線程池大小的。
因為是并行流,所以其實是多線程在并發(fā)操作這個orderListVOS 容器,但是這個容器是不能保證線程安全的。
修改之后:
List<OrderListVO> orderListVOS = Collections .synchronizedList(new LinkedList<OrderListVO>());
這樣就能得到理想的結果。
另外,stream自帶最后的聚合方法:
List<OrderListVO> orderListVOS = orderListVOS.parallelStream() .sorted(Comparator.comparing(OrderListVO::getCreatetime).reversed()) .collect(Collectors.toList());
collect(Collectors.toList()) 方法最后回將操作后的數(shù)據(jù)進行匯總,此方法本身實現(xiàn)了線程安全性的操作,最后得到的結果也會是正確的。
JAVA8之parallelStream()并行流的正確用法
1.因為是并行流,所以所涉及到的數(shù)據(jù)結構
需要使用線程安全的,比如
listByPage.parallelStream().forEach(str-> { //使用線程安全的數(shù)據(jù)結構 //ConcurrentHashMap //CopyOnWriteArrayList //等等進行操作 });
2.默認優(yōu)先用在CPU密集型計算中
這里有的人就說了,用在IO密集比如HTTP請求啊什么的這種耗時高的操作并行去請求不是效果顯著嗎
由于默認并行流使用的是全局的線程池,線程數(shù)量是根據(jù)cpu核數(shù)設置的,所以如果某個操作占用了線程,將影響全局其他使用并行流的操作
所以折中的方案是自定義線程池來執(zhí)行某個并行流操作
ForkJoinPool forkJoinPool = new ForkJoinPool(10); forkJoinPool.execute(() -> { listByPage.parallelStream().forEach(str -> { }); });
以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
springboot?vue測試平臺接口定義及發(fā)送請求功能實現(xiàn)
這篇文章主要為大家介紹了springboot+vue測試平臺接口定義及發(fā)送請求功能實現(xiàn),有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2022-05-05