第三个参数Java8减少对象中的字符串属性

Question

Stream Guru 的问题很简单：

我有这个：

    List<MyBean> beans = new ArrayList<>();
    beans.add(new MyBean("tutu"));
    beans.add(new MyBean("toto"));
    beans.add(new MyBean("titi"));

比较：

 StringBuilder reduced
            = beans.parallelStream()
                    .map(MyBean::getName)
                    .reduce(new StringBuilder(), (builder, name) -> {
                        if (builder.length() > 0) {
                            builder.append(", ");
                        }

                        builder.append(name);
                        return builder;
                    }, (left, right) -> left.append(right));

和

 StringBuilder reduced
            = beans.parallelStream()
                    .map(MyBean::getName)
                    .reduce(new StringBuilder(), (builder, name) -> {
                        if (builder.length() > 0) {
                            builder.append(", ");
                        }

                        builder.append(name);
                        return builder;
                    }/* WITHOUT THIRD PARAM*/);

为什么，第二个解决方案没有编译...第三个参数用于并行流...

您能解释一下为什么我无法编译第二个代码部分吗？

Answer 1

这种行为是因为reduce的这种重载：

reduce(T identity, BinaryOperator<T> accumulator)

接受两个参数，第二个是BinaryOperator<T>，它基本上表示对两个相同类型的操作数的操作，产生与操作数相同类型的结果.在您的第二个代码 sn-p 中没有遵守此约定，因为您的 map 操作返回 Stream<String> 而 identity 的类型为 StringBuilder。为防止编译器错误，只需将 identity 值和 accumulator 函数的操作数设为相同类型，即：

StringBuilder reduced
                = beans.stream()
                .map(b -> new StringBuilder(b.getName()))
                .reduce(new StringBuilder(), (builder, name) -> {
                    if (builder.length() > 0) {
                        builder.append(", ");
                    }

                    builder.append(name);
                    return builder;
                }/* WITHOUT THIRD PARAM*/);

另一方面，reduce 的重载：

reduce(U identity, BiFunction<U,? super T,U> accumulator, BinaryOperator<U> combiner)

接受BiFunction 作为第二个参数，它可以使用两种不同类型的对象，因此您的第一个代码 sn-p 可以在没有编译器错误的情况下工作。

最后，不要忘记将beans.parallelStream() 更改为beans.stream()，如上述解决方案所示。

顺便说一句，请注意，在并行执行操作时，累加器以及组合器，必须为associative 、non-interfering 和 stateless。如果不考虑这一点，您的结果将是非确定性任意结果。

编辑：

如Holger所述：

修改归约函数中的传入参数被 定义，即使它碰巧产生了预期的结果 顺序上下文。也违反了第一个合同 参数，因为修改后的 StringBuilder 不是标识值 了。您可以将 Reduction 与不可变值一起使用，如 .map(MyBean::getName).reduce((a,b) -> a + ", " + b).orElse(""); 或使用 可变约简 .map(MyBean::getName).collect(Collectors.joining(", "));