基于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)文章
springboot?vue測(cè)試平臺(tái)接口定義及發(fā)送請(qǐng)求功能實(shí)現(xiàn)
這篇文章主要為大家介紹了springboot+vue測(cè)試平臺(tái)接口定義及發(fā)送請(qǐng)求功能實(shí)現(xiàn),有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-05-05Java詳解IO流創(chuàng)建讀取與寫(xiě)入操作
這篇文章主要介紹了Java IO流,同時(shí)也介紹了流中的一些相關(guān)的內(nèi)容,并且通過(guò)大量的案例供大家理解。最后通過(guò)一些經(jīng)典的案例幫助大家對(duì)前面所學(xué)的知識(shí)做了一個(gè)綜合的應(yīng)用,需要的朋友可以參考一下2022-05-05Spring Boot設(shè)置支持跨域請(qǐng)求過(guò)程詳解
這篇文章主要介紹了Spring Boot設(shè)置支持跨域請(qǐng)求過(guò)程詳解,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-08-08使用Spring?Boot?2.x構(gòu)建Web服務(wù)的詳細(xì)代碼
這篇文章主要介紹了使用Spring?Boot?2.x構(gòu)建Web服務(wù)的詳細(xì)代碼,主要基于JWT的身份認(rèn)證,本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2022-03-03實(shí)例講解Java讀取一般文本文件和word文檔的方法
讀取一般文本文件很好辦,調(diào)用Java自帶的io包里的類(lèi)即可,富文本的doc文件我們可以用Apache的poi項(xiàng)目中的WordExtractor,這里我們一起來(lái)以實(shí)例講解Java讀取一般文本文件和word文檔的方法2016-06-06Maven中央倉(cāng)庫(kù)發(fā)布的實(shí)現(xiàn)方法
最近做了個(gè)項(xiàng)目,希望能夠上傳到maven中央倉(cāng)庫(kù),給更多的人使用,于是就產(chǎn)生了這次項(xiàng)目發(fā)布經(jīng)歷。感興趣的可以一起來(lái)參考一下2021-06-06