人生要有意义只有发扬生命，快乐就是发扬生命的最好方法。——张闻天
关于reduce我已经写过博客了
今天最后再来聊一聊它的第三个重载
之前一直用得少，所以没有去探究它的妙用
最近稍微抽空看了下
发现还挺有意思的
例如它的第三个参数
在并行流的场景下同样的代码竟有不同的效果
如下：
代码语言：javascript复制public static void main(String[] args) {
sum();
parallelSum();
}
private static void sum() {
List<Integer> list = Stream.generate(() -> 1).limit(100).collect(Collectors.toList());
System.out.println(list);
int sum = list.stream().reduce(1, Integer::sum, (a, b) -> {
System.out.println("stream执行sum时上次结果：[" a "]本次值：[" b "]");
return Integer.sum(a, b);
});
System.out.println(sum);
}
private static void parallelSum() {
List<Integer> list = Stream.generate(() -> 1).limit(100).collect(Collectors.toList());
System.out.println(list);
int sum = list.parallelStream().reduce(1, Integer::sum, (a, b) -> {
System.out.println("parallelStream执行sum时上次结果：[" a "]本次值：[" b "]");
return Integer.sum(a, b);
});
System.out.println(sum);
}仅仅是把stream换成了parallelStream，得到的结果就不一样了
并且可以通过日志看出，上方第一个stream是没有执行我们第三个参数BinaryOperator<U> combiner的
而我们下面的parallelStream却执行了
并且两者返回的值不一样
第一个返回101
是因为我们调用reduce时
给了个默认值为1
再加上我们聚合计算得到的结果为100相加得到101
注意这里我们第三个参数BinaryOperator<U> combiner并没有执行，于是忽略
就像(((默认值1 第一个元素1) 第二个元素1) 第三个元素1) ...这样一直累加，得到结果101
graph LR
普通stream
100个1组成的list -->|第一次累加| 默认值1 第一个元素1
--> 2 -->|第二次累加| 上次得到的结果2 第二个元素1
--> 省略...
第二个返回了164
是因为我们调用reduce时
给了个默认值为1
而我们在并行流计算时，每次计算都会去重复计算一遍这个默认值
就像(默认值1 第一个元素1) (默认值1 第二个元素1) (默认值1 第三个元素1)...这样
但要注意，并行流的内部使用了默认的 ForkJoinPool分支/合并框架，它的默认线程数量就是你的处理器数量
我这里最大线程数为64，因此最多我们的默认值会被多加63次，得到结果164，要注意，可能我的最大线程数并没有这么多，一些线程可能会被重复使用，因此累加次数可能是大于最大线程数
它像一个BUG，一个坑，所以要多多注意，这里我们可以避免这个坑的话，初始值我们给0即可，因为0无论是加一次还是63次都不会影响我们最终的结果~
graph LR
并行流parallelStream
list[100个1组成的list] -->|第一次累加| A[默认值1 第一个元素1] --> C[2] --> final[前面的计算执行完毕后]
list --> 注意是同时执行
list -->|第二次累加| B[默认值1 第一个元素1] --> D[2] --> final
list -->|第...次累加| 默认值1 上次得到的结果 第...个元素1 --> E[x] --> final
final --> 将计算结果再次累加得到最后的结果
