parallelStream

阿超

发布于 2022-08-16 20:32:38

56000

代码可运行

文章被收录于专栏：快乐阿超快乐阿超

运行总次数：0

代码可运行

我又愿中国青年只是向上走，不必理会这冷笑和暗箭。——鲁迅

我们在开发中经常使用stream去处理我们的集合

这里分享一个并行流：parallelStream

它可以允许我们的声明式编程以多线程并行的方式执行

首先我们可以比较一下性能

List<Integer> list = new SecureRandom().ints().limit(10000000).boxed().collect(Collectors.toList());

long startTime = System.nanoTime();
// 求和操作
int sum = list.stream().mapToInt(Integer::intValue).reduce(0, Integer::sum);
System.out.println("普通stream求和结果：" + sum);
long normalStreamEndTime = System.nanoTime();

System.out.println("普通stream耗时：" + ((normalStreamEndTime - startTime) / (1000.0 * 1000.0)) + " ms");
// 求和操作
int parallelSum = list.parallelStream().mapToInt(Integer::intValue).reduce(0, Integer::sum);
System.out.println("parallelStream求和结果：" + parallelSum);
long parallelStreamEndTime = System.nanoTime();
System.out.println("parallelStream耗时：" + ((parallelStreamEndTime - normalStreamEndTime) / (1000.0 * 1000.0)) + " ms");

实验结果