Java并行流_parallelStream的使用方式

　　最近在同事的代码里，发现了->的代码，觉得有点惊讶和疑惑，虽然知道->{}是匿名函数的表达式，但却被parallelStream所吸引。

就像这样的代码：

List<Bom> specialModelNeedToBeSaved = bom.parallelStream()
                        .filter(a->CodeStartWithList.getStartWithListOfModel().contains(a.getScpe().substring(0,2)))
                        .filter(b->"(".equals(b.getScpe().substring(3,4))||"（".equals(b.getScpe().substring(3,4)))
                        .collect(Collectors.toList());

看着挺长挺nb的，百度了才知道parallelStream是一个叫并行流的东西，Java1.8才加入的。它通过默认的ForkJoinPool，提高多线程任务的速度，默认线程数量等于运行计算机上的处理器数量。Java8为ForkJoinPool添加了一个通用线程池，这个线程池用来处理那些没有被显式提交到任何线程池的任务。当调用Arrays类上添加的新方法时，自动并行化就会发生。

注意哦，这里是并行，不是并发。因为是多个处理器同时处理，和并发还是有区别的。

我们可以用parallelStream来处理list里的元素，比如输出：

     TestTwo testTwo = new TestTwo();
     List<Integer> list = new ArrayList<>();
     for(int i=1;i<100;i++)
         list.add(i);
     list.parallelStream().forEach(a->{
         out.println(a);
     });

　这样输出是无序，当然我们也可以让它有序的！forEachOrdered就是按照list的顺序依次执行。

list.parallelStream().forEachOrdered(a->{
    out.println(a);
});

　我们也可以通过fiter来过滤list里的值，需要注意的是后面的匿名函数需要有true，false返回值，以此才能知道，哪些元素是需要被过滤的。

        List<Integer> p2 = list.parallelStream().filter(a->{
            if(a>95){
                return true;
            }else{
                return false;
            }
        }).collect(Collectors.toList());
        p2.parallelStream().forEachOrdered(a->{
            out.println(a);
        });    
    输出：
    96
    97
    98
    99