自定义 ForkJoinPool 提升并行流 ParallelStream 执行速度
简介
在 java8 中 添加了流Stream,可以让你以一种声明的方式处理数据。使用起来非常简单优雅。ParallelStream 则是一个并行执行的流,采用 ForkJoinPool 并行执行任务,提高执行速度。
下面我们看看2个简单的示例:
示例1 (list)
Arrays.asList(1,2,3,4,5,6)
.parallelStream()
.forEach((value) -> {
String name = Thread.currentThread().getName();
System.out.println("示例1 Thread:" + name + " value:" + value);
});
示例2 (array)
Stream.o