java - 为什么永远不会到达collect方法中的BiConsumer Combiner代码？

Question

这个问题已经有答案了:

How does combiner in Stream.collect method work in java 8? (3 个回答)

已关闭 3 年前。

在主方法中，我创建了一个不同年龄的人员列表。现在，当我使用collect方法将该列表转换为人员年龄列表时。BiConsumer组合器函数中的代码永远不会到达。

class Person {
    private int age;

    public int getAge() {
        return age;
    }
}

//collect 的第二种风格

ArrayList<Integer> pAges = people.stream()
                            .collect(ArrayList<Integer>::new, 
                                    (listGivenBySupplier, personObjectFromPeopleStream) -> listGivenBySupplier.add(personObjectFromPeopleStream.getAge()), 
                                    (r1, r2) -> {  //Also please explain what value is passed to r1 and r2
                                            System.out.println("r1: " + r1);
                                            System.out.println("r2: " + r2);
                                            r1.add(2222);
                                            r2.add(2211); 
                            });
System.out.println("pAges:" + pAges);

Answer 1

仅当并行调用流处理管道时才会调用组合器函数。所以改成并行流就应该到达combiner函数了。所以这应该会触发它。

people.parallelStream()...

对于一个实例，假设有 2 个工作线程处理此工作负载。任何并行执行都涉及将源拆分为多个部分，并发执行它们，最后将部分结果合并到一个结果容器中。每个线程 T1 和 T2 都有一个关联的 List，因此容器是线程受限的。累加器函数将每个单个元素添加到关联的容器中。线程 T1 和 T2 完成后，部分容器应合并到一个大结果容器中。这就是组合器功能发挥作用的地方。在串行执行中，不涉及结果的合并，因此组合器在那里没有用处。