Java8 中的ParallelStream
作者:onlythinking 时间:2022-09-07 19:00:23
目录
1、Stream API
2、ParallelStreams执行原理
3、ParallelStreams注意事项
前言:
并行编程势不可挡,Java从1.7开始就提供了Fork/Join 支持并行处理。java1.8 进一步加强。
并行处理就是将任务拆分子任务,分发给多个处理器同时处理,之后合并。
1、Stream API
Java 8 引入了许多特性,Stream API
是其中重要的一部分。区别 InputStream OutputStream
,Stream API
是处理对象流而不是字节流。
执行原理如下,流分串行和并行两种执行方式
// 串行执行流
stream().filter(e -> e > 10).count();
// 并行执行流
.parallelStream().filter(e -> e > 10).count()
2、ParallelStreams执行原理
并行执行时,java
将流划分为多个子流,分散在不同CPU并行处理,然后进行合并。
并行一定比串行更快吗?这不一定,取决于两方面条件:
处理器核心数量,并行处理核心数越多自然处理效率会更高。
处理的数据量越大,优势越强。这也很好理解,比如十个人干一个人就能完成的活儿会比它自己干更便宜?
3、ParallelStreams注意事项
使用并行流时,不要使用collectors.groupingBy,collectors.toMap
,替代为
collectors.groupingByConcurrent , collectors.toConcurrentMap
,或直接使用串行流。
原因,并行流执行时,通过操作Key来合并多个map的操作比较昂贵。详细大家可以查看官网介绍。
https://docs.oracle.com/javase/tutorial/collections/streams/parallelism.html#concurrent_reduction
Map<String, List<Person>> byGender =
roster
.stream()
.collect(Collectors.groupingBy(Person::getGender));
ConcurrentMap<String, List<Person>> byGender =
roster
.parallelStream()
.collect(Collectors.groupingByConcurrent(Person::getGender));
ParallelStreams
默认使用 ForkJoinPool.commonPool()
线程池。
注意:默认情况下,你写的 ParallelStreams 都是通过该线程池调度执行,整个应用程序都共享这个线程池。
看一个例子,我们查询一批新闻数据,可以利用并行化来处理远程新闻下载。
public List<News> queryNews(Stream<String> ids) {
return ids.parallel()
.map(this::getNews) // 网络操作,新闻下载
.collect(toList());
}
因为是网络操作,存在很多不确定性,假如某个任务运行时间较长,导致线程池资源占据,阻塞其它线程,这样就阻止了其他的并行流任务正常进行。
如果解决这个问题的其中一种方式,进行线程池隔离
。那么如何自定义并行流的线程池呢?
ForkJoinPool
构造参数我们默认设置为CPU核心数。
ForkJoinPool customThreadPool = new ForkJoinPool(4);
long actualTotal = customThreadPool
.submit(() -> roster.parallelStream().reduce(0, Integer::sum)).get();
总结:
Java 1.8
提供的Stream API
简化了代码,很好用。不过在使用过程中应该注意以上问题。
来源:https://www.onlythinking.com/2020/06/05/%E4%BD%A0%E5%9C%A8%E4%BD%BF%E7%94%A8java-8-parallel-streams-%E5%90%97%EF%BC%9F/
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
SpringBoot + validation 接口参数校验的思路详解
Java堆&优先级队列示例讲解(上)
![](https://img.aspxhome.com/file/2023/6/64166_0s.jpg)
java8新特性 stream流的方式遍历集合和数组操作
![](https://img.aspxhome.com/file/2023/0/60790_0s.jpg)
基于javaWeb 项目SSM配置要点及可能遇到的问题和解决方法
java 多线程的几种实现方法总结
springmvc+shiro自定义过滤器的实现代码
![](https://img.aspxhome.com/file/2023/9/73059_0s.png)
使用JavaBean根据指定条件设置属性值默认值方式
Android实现悬浮窗的简单方法实例
Java TreeSet类的简单理解和使用
![](https://img.aspxhome.com/file/2023/2/77952_0s.jpg)
Winform项目中TextBox控件DataBindings属性
![](https://img.aspxhome.com/file/2023/0/86990_0s.jpg)
java信号量控制线程打印顺序的示例分享
c#获取本机在局域网ip地址的二种方法
Spring AOP 后置通知修改响应httpstatus方式
![](https://img.aspxhome.com/file/2023/5/78305_0s.jpg)
MyBatis逆向工程的创建和使用
![](https://img.aspxhome.com/file/2023/3/87213_0s.jpg)
IDEA离线安装maven helper插件的图文教程
![](https://img.aspxhome.com/file/2023/3/78053_0s.jpg)
java中Unsafe的使用讲解
SpringBoot2整合activiti6环境搭建过程解析
![](https://img.aspxhome.com/file/2023/9/59379_0s.png)
使用C# 的webBrowser写模拟器时的javascript脚本调用问题
Android WindowManger实现桌面悬浮窗功能
![](https://img.aspxhome.com/file/2023/6/84706_0s.webp)