快捷導(dǎo)航

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

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

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

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ì)算中

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

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

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

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

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

您可能感興趣的文章: