快捷導(dǎo)航

基于Java8并行流(parallelStream)的注意點

更新時間：2021年07月28日 10:29:47 作者：寧采野花不采臣

這篇文章主要介紹了Java8并行流(parallelStream)的注意點，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

Java8并行流（parallelStream）注意點

在最初使用并行流的時候，查詢列表會偶爾性報空指針異常，這令我非常納悶

代碼是這樣的：

List<OrderListVO> orderListVOS = new LinkedList<OrderListVO>();

baseOrderBillList.parallelStream().forEach(baseOrderBill -> {
   OrderListVO orderListVO = new OrderListVO();
   // 設(shè)置order中的屬性

   orderListVO.setOrderbillgrowthid(baseOrderBill.getOrderbillgrowthid());
   orderListVO.setOrderbillid(baseOrderBill.getOrderbillid());
   ……
   orderListVOS.add(orderListVO);
}

代碼本身是在做多表拆分然后業(yè)務(wù)層組裝，使用并行流能夠提升這種純粹的CPU密集型操作，parallelStream 此方法默認(rèn)是以服務(wù)器CPU核數(shù)為線程池大小的。

因為是并行流，所以其實是多線程在并發(fā)操作這個orderListVOS 容器，但是這個容器是不能保證線程安全的。

修改之后：

List<OrderListVO> orderListVOS = Collections
.synchronizedList(new LinkedList<OrderListVO>());

這樣就能得到理想的結(jié)果。

另外，stream自帶最后的聚合方法：

List<OrderListVO> orderListVOS = orderListVOS.parallelStream()
                .sorted(Comparator.comparing(OrderListVO::getCreatetime).reversed())
                .collect(Collectors.toList());

collect(Collectors.toList()) 方法最后回將操作后的數(shù)據(jù)進行匯總，此方法本身實現(xiàn)了線程安全性的操作，最后得到的結(jié)果也會是正確的。

JAVA8之parallelStream()并行流的正確用法

1.因為是并行流，所以所涉及到的數(shù)據(jù)結(jié)構(gòu)

需要使用線程安全的，比如

listByPage.parallelStream().forEach(str-> {
           //使用線程安全的數(shù)據(jù)結(jié)構(gòu)
           //ConcurrentHashMap
           //CopyOnWriteArrayList
           //等等進行操作
        });

2.默認(rèn)優(yōu)先用在CPU密集型計算中

這里有的人就說了，用在IO密集比如HTTP請求啊什么的這種耗時高的操作并行去請求不是效果顯著嗎

由于默認(rèn)并行流使用的是全局的線程池，線程數(shù)量是根據(jù)cpu核數(shù)設(shè)置的，所以如果某個操作占用了線程，將影響全局其他使用并行流的操作

所以折中的方案是自定義線程池來執(zhí)行某個并行流操作

  ForkJoinPool forkJoinPool = new ForkJoinPool(10);
        forkJoinPool.execute(() -> {
            listByPage.parallelStream().forEach(str -> {
                
            });
        });

以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: