在还原操作中从不调用合并器（但它是强制性的）

Question

    List<User> users = Arrays.asList(new User("John", 30), new User("Julie", 35));

    int result = users.stream()
            .reduce(0,
                    (partialAgeResult, user) -> {
                        // accumulator is called twice
                        System.out.println(MessageFormat.format("partialAgeResult {0}, user {1}", partialAgeResult, user));
                        return partialAgeResult + user.getAge();
                    },
                    (integer, integer2) -> {
                        // combiner is never called
                        System.out.println(MessageFormat.format("integer {0}, integer2 {1}", integer, integer2));
                        return integer * integer2;
                    });

    System.out.println(MessageFormat.format("Result is {0}", result)); 

Answer 1

问题就在这里。您在合并器中是乘法而不是加法。

 (integer, integer2) -> {
                        // combiner is never called
                        System.out.println(MessageFormat.format("integer {0}, integer2 {1}", integer, integer2));
                        return integer * integer2; //<----- Should be addition
                    });

组合器用于适当地组合并行操作的各个部分，因为这些操作可以在原始流的各个“部分”上独立执行。

一个简单的例子是求和一个元素列表。在并行操作中可以有多种部分和，因此您需要在合并器中对部分和求和以得到总和（这是一个很好的练习，您可以亲自尝试查看）。