为什么永远达不到收集方法中的这个Bi消费者组合器代码？[复制]

Question

在主要方法中，我列出了不同年龄的人。现在，当我使用collect方法将此列表转换为一个人员年龄列表时。双消费组合器函数中的代码永远达不到。

class Person {
    private int age;

    public int getAge() {
        return age;
    }
}

//收藏的第二味道

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

仅当并行调用流处理管道时，才会调用合并器函数。因此，将其更改为并行流，然后它应该达到合并器功能。所以这应该会触发它。

people.parallelStream()...

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