最近在同事的代码里,发现了->的代码,觉得有点惊讶和疑惑,虽然知道->{}是匿名函数的表达式,但却被parallelStream所吸引。
就像这样的代码:
复制代码
List 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());
//代码效果参考:http://www.zidongmutanji.com/zsjx/323075.html
看着挺长挺nb的,百度了才知道parallelStream是一个叫并行流的东西,Java1.8才加入的。它通过默认的ForkJoinPool,提高多线程任务的速度,默认线程数量等于运行计算机上的处理器数量。Java8为ForkJoinPool添加了一个通用线程池,这个线程池用来处理那些没有被显式提交到任何线程池的任务。当调用Arrays类上添加的新方法时,自动并行化就会发生。
注意哦,这里是并行,不是并发。因为是多个处理器同时处理,和并发还是有区别的。
我们可以用parallelStream来处理list里的元素,比如输出:
复制代码
TestTwo testTwo = new TestTwo();
List list = new ArrayList<>();
for(int i=1;i<100;i++) list.add(i); list.parallelStream().forEach(a->{
out.println(a);
});
//代码效果参考:http://www.zidongmutanji.com/bxxx/341800.html
这样输出是无序,当然我们也可以让它有序的!forEachOrdered就是按照list的顺序依次执行。
list.parallelStream().forEachOrdered(a->{
out.println(a);
});
我们也可以通过fiter来过滤list里的值,需要注意的是后面的匿名函数需要有true,false返回值,以此才能知道,哪些元素是需要被过滤的。
复制代码
List p2 = list.parallelStream().filter(a->{
if(a>95){
return true;
}else{
return false;
}
}).collect(Collectors.toList());
p2.parallelStream().forEachOrdered(a->{
out.println(a);
});