欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

基于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();
   // 設置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)

    這篇文章主要為大家介紹了springboot+vue測試平臺接口定義及發(fā)送請求功能實現(xiàn)，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
    2022-05-05
  • Java詳解IO流創(chuàng)建讀取與寫入操作

    Java詳解IO流創(chuàng)建讀取與寫入操作

    這篇文章主要介紹了Java IO流，同時也介紹了流中的一些相關的內容，并且通過大量的案例供大家理解。最后通過一些經典的案例幫助大家對前面所學的知識做了一個綜合的應用,需要的朋友可以參考一下
    2022-05-05
  • Spring Boot設置支持跨域請求過程詳解

    Spring Boot設置支持跨域請求過程詳解

    這篇文章主要介紹了Spring Boot設置支持跨域請求過程詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2020-08-08
  • 詳解Java中的鎖Lock和synchronized

    詳解Java中的鎖Lock和synchronized

    鎖是Java并發(fā)編程中最重要的同步機制，Java提供了種類豐富的鎖，每種鎖因其特性的不同，在適當?shù)膱鼍跋履軌蛘宫F(xiàn)出非常高的效率。本文將詳細介紹Lock和synchronized
    2021-06-06
  • 使用Spring?Boot?2.x構建Web服務的詳細代碼

    使用Spring?Boot?2.x構建Web服務的詳細代碼

    這篇文章主要介紹了使用Spring?Boot?2.x構建Web服務的詳細代碼,主要基于JWT的身份認證，本文通過實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
    2022-03-03
  • 實例講解Java讀取一般文本文件和word文檔的方法

    實例講解Java讀取一般文本文件和word文檔的方法

    讀取一般文本文件很好辦,調用Java自帶的io包里的類即可,富文本的doc文件我們可以用Apache的poi項目中的WordExtractor,這里我們一起來以實例講解Java讀取一般文本文件和word文檔的方法
    2016-06-06
  • Java中枚舉的使用方法詳解

    Java中枚舉的使用方法詳解

    這篇文章主要介紹了Java中枚舉的使用方法詳解,比如我們想聲明一組季節(jié)的集合，那這里面最多有四種，即春夏秋冬，不允許有其他的季節(jié)，那為了實現(xiàn)這種限制，體現(xiàn)出季節(jié)是固定的四個對象，我們可以使用枚舉,需要的朋友可以參考下
    2023-07-07
  • JVM鉤子函數(shù)的使用場景詳解

    JVM鉤子函數(shù)的使用場景詳解

    當jvm進程退出的時候,或者受到了系統(tǒng)的中斷信號,hook線程就會啟動,一個線程可以注入多個鉤,下面這篇文章主要給大家介紹了關于JVM鉤子函數(shù)使用的相關資料,需要的朋友可以參考下
    2021-08-08
  • java中文傳值亂碼問題的解決方法

    java中文傳值亂碼問題的解決方法

    這篇文章主要為大家詳細介紹了java中文傳值亂碼問題的解決方法，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2016-11-11
  • Maven中央倉庫發(fā)布的實現(xiàn)方法

    Maven中央倉庫發(fā)布的實現(xiàn)方法

    最近做了個項目，希望能夠上傳到maven中央倉庫，給更多的人使用，于是就產生了這次項目發(fā)布經歷。感興趣的可以一起來參考一下
    2021-06-06

最新評論