基于Java8并行流有哪些需要注意的地方

這篇文章主要介紹了基于Java8并行流有哪些需要注意的地方，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

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);
}

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

因為是并行流，所以其實是多線程在并發操作這個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()) 方法最后回將操作后的數據進行匯總，此方法本身實現了線程安全性的操作，最后得到的結果也會是正確的。

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

1.因為是并行流，所以所涉及到的數據結構

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

listByPage.parallelStream().forEach(str-> {
           //使用線程安全的數據結構
           //ConcurrentHashMap
           //CopyOnWriteArrayList
           //等等進行操作
        });

2.默認優先用在CPU密集型計算中

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

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

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

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

感謝你能夠認真閱讀完這篇文章，希望小編分享的“基于Java8并行流有哪些需要注意的地方”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關注億速云行業資訊頻道，更多相關知識等著你來學習!