使用示例
public class Test {
public static void main(String[] args) throws Exception{
//计算0到1000的累加和
int reduce = IntStream.rangeClosed(0, 10000).parallel().reduce(0, (a, b) -> {
return a + b;
});
System.out.println(reduce);
List<Integer> lists = new ArrayList<>();
lists.add(1);
lists.add(2);
lists.add(3);
lists.add(4);
lists.add(5);
lists.add(6);
//并行流
Optional<Integer> sum = lists.parallelStream().reduce((a, b) -> a + b);
System.out.println(sum.get());
}
}
结果:
500500
21