关于parallelStream的一次踩坑

Stream 是JAVA8引入的一个新的抽象，为了提高性能同时也加入了parallelStream(并行流)
看下面一段代码

        Map<String,String> map = new HashMap<>();
        map.put("1","2");//1
        List<Map<String,Integer>> mapsL = new ArrayList<>();//2


        for(int i=0;i<100000;i++){//3
            Map<String,Integer> map1 = new HashMap<>();
            map1.put("key",i);
            mapsL.add(map1);
        }
        List<Map<String,Integer>> maps2 = new ArrayList<>();
        mapsL.parallelStream().filter(
                iter-> iter.get("key") <20000
        ).forEach(maps2::add);//4
        if(maps2.size()<20000){//5
            System.out.println("forEach Error !"+maps2.size());//6
        }

从表面看上去相安无事，输出语句并不会运行。
其实并不然
你把这个段代码粘贴并运行之后,会发现输出语句是有输出的。

这个时候心里就会产生疑问这是为什么呢？所有的操作看上去都是合理的而且符合java语法的。

我们一起来重读一下代码

• 代码1到3为正常创建添加操作，模仿我们从数据源查出的数据集
• 代码4是一个并行的流
  • 过滤key对应的值小于20000的操作
  • 将过滤后的值add到naps2中
• 5是逻辑判断

我们在面对一个巨型的集合时候，Stream的串行操作是无法我们对性能的追求的，那这个时候最好的操作就是采用多线程或者parallelStream并行流，无论是前者还是后者，都要面临一个问题——线程安全。
哦，这个时候就不难明白为啥上面maps2的SIZE会小于20000，罪魁祸首就是上面的代码4，

• ArrayList是一个非线程安全类
• forEach 的操作是无顺序控制的

问题找到了，我相信大家会有更多的办法去解决 ，无论是使用线程安全的Vector ，亦或者使用forEachOrdered，或者不做迭代操作直接使用.collect(Collectors.toList()) 的操作都是可以解决上面的问题的。

        Map<String,String> map = new HashMap<>();
        map.put("1","2");
        List<Map<String,Integer>> mapsL = new ArrayList<>();


        for(int i=0;i<100000;i++){
            Map<String,Integer> map1 = new HashMap<>();
            map1.put("key",i);
            mapsL.add(map1);
        }



        for(int i=0;i<10000;i++){
            List<Map<String,Integer>> list= mapsL.parallelStream().filter(
                    iter-> iter.get("key") <20000
            ).collect(Collectors.toList()); //方案1 推荐

            List<Map<String,Integer>> maps2 = new Vector<>();
            mapsL.parallelStream().filter(
                    iter-> iter.get("key") <20000
            ).forEach(maps2::add); //方案2

            List<Map<String,Integer>> maps3 = new ArrayList<>();
            mapsL.parallelStream().filter(
                    iter-> iter.get("key") <20000
            ).forEachOrdered(maps3::add); // 方案3

            if(maps3.size()<20000){
                System.out.println("forEach Error !"+maps2.size());
            }

            if(maps2.size()<20000){
                System.out.println("forEach Error !"+maps2.size());
            }

            if(list.size()<20000){
                System.out.println("Collect Error !"+list.size());
            }

            //方案 N。。。。。。。。。。。。。
        }