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

代码本身是在做多表拆分然后业务层组装，使用并行流能够提升这种纯粹的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 -> {
                
            });
        });

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

Java如何通过属性名获取Object对象属性值
这篇文章主要介绍了Java如何通过属性名获取Object对象属性值问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2024-07-07
java8 stream自定义分组求和并排序的实现
这篇文章主要介绍了java8 stream自定义分组求和并排序的实现,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-01-01
JavaWeb实现用户登录注册功能实例代码(基于Servlet+JSP+JavaBean模式)
这篇文章主要基于Servlet+JSP+JavaBean开发模式实现JavaWeb用户登录注册功能实例代码，非常实用，本文介绍的非常详细，具有参考借鉴价值，感兴趣的朋友一起看看吧
2016-05-05
程序包org.springframework不存在的解决办法
这篇文章主要介绍了程序包org.springframework不存在的解决办法,在使用IDEA创建SpringBoot项目时,刚打开无法正常运行,本文通过图文结合的方式给大家介绍的非常详细,具有一定参考价值,需要的朋友可以参考下
2024-07-07
Java阻塞队列必看类:BlockingQueue快速了解大体框架和实现思路
这篇文章主要介绍了Java阻塞队列必看类:BlockingQueue快速了解大体框架和实现思路，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-10-10
Java ReentrantLock的使用与应用实战
ReentrantLock是Java并发包中提供的一种可重入互斥锁,它作为synchronized关键字的替代方案,提供了更灵活、更强大的线程同步机制,下面就来介绍一下ReentrantLock的实战使用
2025-09-09
SpringBoot整合SpringSecurity实现图形验证码功能
图形验证码是一种用于区分用户是人类还是计算机程序的自动化测试,它通常用于防止自动化软件进行恶意操作,如滥用在线服务、暴力破解密码或进行垃圾邮件发送等,下面将介绍 Spring Boot 整合 Spring Security 实现图形验证码功能,需要的朋友可以参考下
2024-12-12
在Java中如何对类进行排序详解
这篇文章主要给大家介绍了关于如何在Java中使用Arrays.toString()对类进行排序的相关资料,文中通过代码示例介绍的非常详细,需要的朋友可以参考下
2023-08-08
idea已经提交到远程分支,但需要本地和远程都回退到某一版本问题
这篇文章主要介绍了idea已经提交到远程分支,但需要本地和远程都回退到某一版本问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2023-11-11
基于多线程中join()的用法实例讲解
下面小编就为大家带来一篇基于多线程中join()的用法实例讲解。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-10-10