基于Java8并行流(parallelStream)的注意點(diǎn)
Java8并行流（parallelStream）注意點(diǎn)
在最初使用并行流的時(shí)候，查詢列表會(huì)偶爾性報(bào)空指針異常，這令我非常納悶
代碼是這樣的：
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ù)為線程池大小的。
因?yàn)槭遣⑿辛?，所以其?shí)是多線程在并發(fā)操作這個(gè)orderListVOS 容器，但是這個(gè)容器是不能保證線程安全的。
修改之后：
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ù)進(jìn)行匯總，此方法本身實(shí)現(xiàn)了線程安全性的操作，最后得到的結(jié)果也會(huì)是正確的。
JAVA8之parallelStream()并行流的正確用法
1.因?yàn)槭遣⑿辛?，所以所涉及到的?shù)據(jù)結(jié)構(gòu)
需要使用線程安全的，比如
listByPage.parallelStream().forEach(str-> {
//使用線程安全的數(shù)據(jù)結(jié)構(gòu)
//ConcurrentHashMap
//CopyOnWriteArrayList
//等等進(jìn)行操作
});
2.默認(rèn)優(yōu)先用在CPU密集型計(jì)算中
這里有的人就說(shuō)了，用在IO密集比如HTTP請(qǐng)求啊什么的這種耗時(shí)高的操作并行去請(qǐng)求不是效果顯著嗎
由于默認(rèn)并行流使用的是全局的線程池，線程數(shù)量是根據(jù)cpu核數(shù)設(shè)置的，所以如果某個(gè)操作占用了線程，將影響全局其他使用并行流的操作
所以折中的方案是自定義線程池來(lái)執(zhí)行某個(gè)并行流操作
ForkJoinPool forkJoinPool = new ForkJoinPool(10);
forkJoinPool.execute(() -> {
listByPage.parallelStream().forEach(str -> {
});
});
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
Java如何通過(guò)屬性名獲取Object對(duì)象屬性值
這篇文章主要介紹了Java如何通過(guò)屬性名獲取Object對(duì)象屬性值問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-07-07
java8 stream自定義分組求和并排序的實(shí)現(xiàn)
這篇文章主要介紹了java8 stream自定義分組求和并排序的實(shí)現(xiàn),文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-01-01
JavaWeb實(shí)現(xiàn)用戶登錄注冊(cè)功能實(shí)例代碼(基于Servlet+JSP+JavaBean模式)
這篇文章主要基于Servlet+JSP+JavaBean開(kāi)發(fā)模式實(shí)現(xiàn)JavaWeb用戶登錄注冊(cè)功能實(shí)例代碼，非常實(shí)用，本文介紹的非常詳細(xì)，具有參考借鑒價(jià)值，感興趣的朋友一起看看吧2016-05-05
程序包org.springframework不存在的解決辦法
這篇文章主要介紹了程序包org.springframework不存在的解決辦法,在使用IDEA創(chuàng)建SpringBoot項(xiàng)目時(shí),剛打開(kāi)無(wú)法正常運(yùn)行,本文通過(guò)圖文結(jié)合的方式給大家介紹的非常詳細(xì),具有一定參考價(jià)值,需要的朋友可以參考下2024-07-07
Java阻塞隊(duì)列必看類(lèi):BlockingQueue快速了解大體框架和實(shí)現(xiàn)思路
這篇文章主要介紹了Java阻塞隊(duì)列必看類(lèi):BlockingQueue快速了解大體框架和實(shí)現(xiàn)思路，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2022-10-10
Java ReentrantLock的使用與應(yīng)用實(shí)戰(zhàn)
ReentrantLock是Java并發(fā)包中提供的一種可重入互斥鎖,它作為synchronized關(guān)鍵字的替代方案,提供了更靈活、更強(qiáng)大的線程同步機(jī)制,下面就來(lái)介紹一下ReentrantLock的實(shí)戰(zhàn)使用2025-09-09
SpringBoot整合SpringSecurity實(shí)現(xiàn)圖形驗(yàn)證碼功能
圖形驗(yàn)證碼是一種用于區(qū)分用戶是人類(lèi)還是計(jì)算機(jī)程序的自動(dòng)化測(cè)試,它通常用于防止自動(dòng)化軟件進(jìn)行惡意操作,如濫用在線服務(wù)、暴力破?解密碼或進(jìn)行垃圾郵件發(fā)送等,下面將介紹?Spring?Boot?整合?Spring?Security?實(shí)現(xiàn)圖形驗(yàn)證碼功能,需要的朋友可以參考下2024-12-12
在Java中如何對(duì)類(lèi)進(jìn)行排序詳解
這篇文章主要給大家介紹了關(guān)于如何在Java中使用Arrays.toString()對(duì)類(lèi)進(jìn)行排序的相關(guān)資料,文中通過(guò)代碼示例介紹的非常詳細(xì),需要的朋友可以參考下2023-08-08
idea已經(jīng)提交到遠(yuǎn)程分支,但需要本地和遠(yuǎn)程都回退到某一版本問(wèn)題
這篇文章主要介紹了idea已經(jīng)提交到遠(yuǎn)程分支,但需要本地和遠(yuǎn)程都回退到某一版本問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-11-11
下面小編就為大家?guī)?lái)一篇基于多線程中join()的用法實(shí)例講解。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-10-10