Java 8 Stream.reduce()方法的第三个参数

Java 8 Stream.reduce()方法的第三个参数

combiner函数

combiner函数是Stream.reduce()方法的第三个参数，它用于在并行处理流时合并归约的部分结果。它只在结果类型和流元素类型不同时需要。

为什么需要combiner函数？

当我们把一个流转换为另一种类型的值时，我们需要提供一个combiner函数，否则会出现编译错误。例如，如果我们想把一个字符串流归约为一个整数，表示它们的总和，我们需要提供一个combiner函数来合并不同子流的整数值。

如何使用combiner函数？

我们可以使用lambda表达式或方法引用来定义combiner函数。它必须满足结合律，即(a, b) -> f(a, b)和(b, a) -> f(b, a)得到相同的结果。否则，我们可能会得到不正确或不一致的结果。

举例说明

假设有一个字符串流，每个字符串都是一个数字，我们想把它们归约为一个整数，表示它们的总和。可以这样写：

Stream<String> stream = Stream.of("1", "2", "3", "4", "5");
int sum = stream.reduce(0, (a, b) -> a + Integer.parseInt(b), (a, b) -> a + b);
System.out.println(sum); // 15

这里，第一个参数是归约的初始值，第二个参数是累加器函数，它把每个字符串转换为整数并加到累加器上，第三个参数是combiner函数，它把两个累加器的值相加。
如果不提供combiner函数，会得到一个编译错误，因为结果类型（int）和流元素类型（String）不匹配。

如果我们提供了一个错误的combiner函数，例如(a, b) -> a，可能会得到错误或不一致的结果。这取决于Stream是顺序还是并行的。如果是顺序的，combiner函数不会被调用，所以结果还是正确的。如果是并行的，combiner函数会被用来合并不同线程的累加器，这时结果就会错误。例如：

Stream<String> stream = Stream.of("1", "2", "3", "4", "5");
int sum = stream.parallel().reduce(0, (a, b) -> a + Integer.parseInt(b), (a, b) -> a);
System.out.println(sum); // 1

这里，结果是1，而不是15，因为combiner函数只返回了第一个子流的结果，忽略了其他子流的结果。