在流的collect（）终端操作中，如果supplier是字符串之类的不可变对象，会发生什么情况？

Question

Stream的Collection（）方法是一个可变的约简。基于Java文档：

可变缩减操作在处理流中的元素时，将输入元素累积到可变结果容器中，例如Collection或StringBuilder。

我尝试了以下方法，它编译没有问题。

Stream<String> stream1 = Stream.of("w", "o", "l", "f");
String word = stream1.collect(String::new, String::concat, String::concat);
System.out.println(word);

如果供应商是StringBuffer，我将收集操作视为元素将附加到提供的StringBuffer。

既然String是一个不可变的对象，那么可变约简在这里是如何工作的？它是否与每次实现累加器时创建新对象的reduce操作相同？

Answer 1

根据Oracle/Java留档：

收集

<R> R collect(Supplier<R> supplier, <R,? super T> accumulator, <R,R> combiner)

对该流的元素执行可变缩减操作。可变约简是这样一种约简，其中约简的值是可变的结果容器，例如ArrayList，元素通过更新结果的状态而不是替换结果来合并。

https://docs.oracle.com/javase/8/docs/api/java/util/stream/Stream.html#collect-java.util.function.Supplier-java.util.function.BiConsumer-java.util.function.BiConsumer-

可变约简

可变约简操作在处理流中的元素时，将输入元素累积到可变结果容器中，例如Collection或StringBuilder。如果我们想获取一个字符串流并将它们连接成一个长字符串，我们可以通过普通约简来实现这一点：

字符串连接=字符串。reduce（“”，字符串：：concat）

https://docs.oracle.com/javase/8/docs/api/java/util/stream/package-summary.html#MutableReduction

因此，简而言之，它之所以有效，是因为java在幕后使用stringbuilder

Answer 2

由于String是一个不可变对象，可变缩减在这里是如何工作的？

没有。当您运行时，您将得到一个空字符串（仅供应商的结果）。如果供应商返回一个不可变对象，编译器无法强制检查，这绝对是它无法做到的。而且由于您的容器是不可变的，因此对它的更新被简单地忽略了。这就像这样做：

String s = "abc";
s.concat("def"); // the result is ignored here

如果你把它写成lambda，可能会更有意义：

Stream<String> stream1 = Stream.of("w", "o", "l", "f");
    String word = stream1.collect(
            String::new,
            (left, right) -> {
                left.concat(right); // result is ignored
            },
            String::concat);

另一方面，当您使用reduce时，您必须返回一些内容：

String word = stream1.reduce(
            "",
            (x, y) -> {
                return x.concat(y);
            },
            (x, y) -> {
                return x.concat(y);
            });

当然，您仍然可以：

String word = stream1.reduce(
            "",
            (x, y) -> {
                x.concat(y);
                return x; // kind of stupid, but you could
            },
            (x, y) -> {
                return x.concat(y);
            });

如果你想打破它；但这不是重点。