Java教程

关于Java8并行流处理丢数据和数组下标越界的问题

本文主要是介绍关于Java8并行流处理丢数据和数组下标越界的问题,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

背景

Java 8 list的并行流处理,会造成数组下标越界和数据丢失情况。
如下所示:

List<Integer> list = new ArrayList<>();
for(int i=0;i<1000;i++){
    list.add(i+1);
}
System.out.println("原始集合大小:"+list.size());
List<Integer> newList = new ArrayList<>();
list.parallelStream().forEach(
     num->newList.add(num)
);
System.out.println("新集合大小:"+newList.size());

结果一(数组下标越界)
在这里插入图片描述
结果二(数据丢失)
在这里插入图片描述

原因

Java 8 提供了集合的流处理方式,可以通过链路方式快速的对集合对象进行业务处理,其中stream 和parallelStream,分别对应串行和并行流操作。

parallelStream 并行流操作由于底层采用的是ForkJobTask。Fork/Join的框架是通过把一个大任务不断fork成许多子任务,然后多线程执行这些子任务,最后再Join这些子任务得到最终结果。从程序上看,就是先将list集合fork成多段,然后多线程添加到streamList的结合中,而list是ArrayList类型,非线程安全,它的add方法并不能保证原子性。

解决方案

将接收数据的 Arraylist 改为 同步类 SynchronizedList

在这里插入图片描述
运行结果:
在这里插入图片描述

这篇关于关于Java8并行流处理丢数据和数组下标越界的问题的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!