个人中心
gpt4 book ai didi

解决JDK8的ParallelStream遍历无序的问题

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 26 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章解决JDK8的ParallelStream遍历无序的问题由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

JDK8的ParallelStream遍历无序

ParallelStream其实就是一个并行执行的流

它通过默认的ForkJoinPool，可能提高你的多线程任务的速度. 。

Stream具有平行处理能力，处理的过程会分而治之，也就是将一个大任务切分成多个小任务，这表示每个任务都是一个操作，因此像以下的程式片段:

?
1
2
3
List   
        list = Arrays.asList( 1 , 2 , 3 , 4 , 5 );
list.parallelStream().forEach(out::println);

你得到的展示顺序不一定会是1、2、3、4、5，而可能是任意的顺序，就forEach()这个操作來讲，如果平行处理时，希望最后顺序是按照原来Stream的数据顺序，那可以调用forEachOrdered().

?
1
2
3
List   
        list = Arrays.asList( 1 , 2 , 3 , 4 , 5 );
list.parallelStream().forEachOrdered(out::println);

parallelStream进行遍历的坑,以及如何进行避免异步操作中出现的问题

Java8 已经很久了，现在都已经Java12版本了. 。

我所在的上家公司，在写代码时候推荐使用lambad来进行操作遍历集合 。

也就是像下面一样 。

?
1
2
3
4
5
6
7
List<Integer> list = new ArrayList<>();
for ( int j = 0 ; j < 1000 ; j++) {
list.add(j);
}
list.stream().forEach(value -> {
System.out.println(value);
});

这种效率其实和传统上的使用foreach以及for循环遍历效果差不多，因为点开forEach方法会发现内部其实使用的是下面的方法进行对集合遍历的 。

解决JDK8的ParallelStream遍历无序的问题

内部其实使用的还是for进行遍历，所以两者相比较其实没有什么效率的差异的，当然这也会由于每个公司编程习惯不一样，有的人更喜欢传统上的for进行遍历 。

因为上面的遍历方式不会对效率有什么提升, 所以由此还有一种方式就是 。

?
1
parallelStream()
?
1
2
3
4
5
6
7
List<Integer> list = new ArrayList<>();
for ( int j = 0 ; j < 1000 ; j++) {
list.add(j);
}
list.parallelStream().forEach(value -> {
System.out.println(value);
});

上面的方法其实就是异步的， 。

这种遍历方式因为是异步遍历，会产生一种情况，就是遍历的顺序是无序的，当然也有相应的好处就是，遍历速度会快，当对生成结果不考虑排序问题而且数据量比较大的时候可以使用. 。

但是，有利自然有弊，因为异步的所以需要考虑线程的问题，就是生成的结果真的是你想要的么？

以下面的例子来运行一段代码:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
public static void main(String[] args) {
List<Integer> list = new ArrayList<>();
for ( int j = 0 ; j < 1000 ; j++) {
list.add(j);
}
System.out.println( "最开始生成的集合长度:" +list.size());
//parallelStream遍历数据的时候会产生丢失的问题
for ( int i = 0 ; i < 10 ; i++) {
  
List<Integer> parseList = new ArrayList<>();
list.parallelStream().forEach(integer -> {
parseList.add(integer);
});
System.out.println( "每次遍历的集合长度:" + parseList.size());
}
}

我首先创建了一个1000长度的集合，之后对这个集合使用多次遍历，然而呢，会发现，最后遍历的集合少数据，并且会在多次重复遍历的时候数组越界.. 。

解决JDK8的ParallelStream遍历无序的问题

因为这种情况，之前工作使用parallelStream出现过2次问题， 我一直以为是使用parallelStream本身不够很安全导致的.实际上今天整理这篇博文突然才发现这个问题，就是遍历的结果转为的list是线程安全的么？

其实当正常进行遍历的时候， 可以对遍历出的结果核对，实际上每次遍历出的结果，仍然是与原来生成的结果一致的. 。

解决JDK8的ParallelStream遍历无序的问题

所以这边只能将锅甩在接收这些数据的list上面了 。

这个时候就需要对list进行包装 。

?
1
List<Integer> synchronizedList = Collections.synchronizedList(parseList);

这会在看下修改后的代码以及结果 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
public static void main(String[] args) {
List<Integer> list = new ArrayList<>();
for ( int j = 0 ; j < 1000 ; j++) {
list.add(j);
}
System.out.println( "最开始生成的集合长度:" +list.size());
//parallelStream遍历数据的时候会产生丢失的问题
for ( int i = 0 ; i < 10 ; i++) {
  
List<Integer> parseList = new ArrayList<>();
List<Integer> synchronizedList = Collections.synchronizedList(parseList);
list.parallelStream().forEach(integer -> {
synchronizedList.add(integer);
});
System.out.println( "每次遍历的集合长度:" + synchronizedList.size());
}
}

解决JDK8的ParallelStream遍历无序的问题

这样每次遍历的结果也都是一样的，而且速度也会由于异步的会比之前效率提升好多 。

解决JDK8的ParallelStream遍历无序的问题

同样的如何创建线程安全的set，map也就可以进行相应的包装，这样就避免了使用会出新一些明明感觉对，确和自己想要的结果不一致的bug 。

同理使用parallelStream用StringBuffer 而不适用StringBuilder，因为前者是线程安全的 。

以上为个人经验，希望能给大家一个参考，也希望大家多多支持我.

原文链接：https://blog.csdn.net/u011051912/article/details/77051335 。

最后此篇关于解决JDK8的ParallelStream遍历无序的问题的文章就讲到这里了,如果你想了解更多关于解决JDK8的ParallelStream遍历无序的问题的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

26 4 0
文章推荐： 你需要了解的VMware云回迁选项
文章推荐： SpringBoot与SpringMVC中参数传递的原理解析
文章推荐： 基于Java8并行流(parallelStream)的注意点
文章推荐： Java实现消消乐中的消除功能
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com