Java并行流_parallelStream的使用方式

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

就像这样的代码：

List<Bom> specialModelNeedToBeSaved = bom.parallelStream()
        .filter(a->CodeStartWithList.getStartWithListOfModel().contains(a.getScpe().substring()))
        .filter(b->.equals(b.getScpe().substring())||.equals(b.getScpe().substring()))
        .collect(Collectors.())

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

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

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

TestTwo testTwo = TestTwo()List<Integer> list = ArrayList<>()(i=i<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->{
    (a>){
        }{
        }
}).collect(Collectors.())p2.parallelStream().forEachOrdered(a->{
    out.println(a)})

输出：    96
    97
    98
    99