背景

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

运行结果：