使用身份组合器并行流减少

Question

final Stream<Integer> numbers = Stream.of(5, 3, 2, 7, 3, 13, 7).parallel();

为什么下面一行的输出是7？

 numbers.reduce(1, (a, b) -> a + b, (x, y) -> x - y)); 

Answer 1

我没有查看 cmets 中的那个链接，但是文档对 identity 非常清楚，它甚至提供了一种简单的测试方法：

标识值必须是组合器函数的标识。这意味着对于所有 u，combiner(identity, u) 等于 u

所以让我们稍微简化一下你的例子：

Stream<Integer> numbers = Stream.of(3, 1).parallel();
BiFunction<Integer, Integer, Integer> accumulator = (a, b) -> a + b;

BiFunction<Integer, Integer, Integer> combiner = (x, y) -> x - y; 

    int result = numbers.reduce(
            1,
            accumulator,
            combiner);

    System.out.println(result);

假设u = 3（只是流中的一个随机元素），因此：

    int identity = 1;
    int u = 3;

    int toTest = combiner.apply(identity, u);
    System.out.println(toTest == identity); // must be true, but is false

即使您认为将身份替换为zero，也可以；文档提出了另一个论点：

另外，combiner 函数必须与 accumulator 函数兼容；对于所有 u 和 t，必须满足以下条件：

 combiner.apply(u, accumulator.apply(identity, t)) == accumulator.apply(u, t)

你可以做同样的测试：

int identity = 0;
int u = 3;
int t = 1;

boolean associativityRespected = 
     combiner.apply(u, accumulator.apply(identity, t)) == accumulator.apply(u, t);
System.out.println(associativityRespected); // prints false