为什么java流“reduce（）”会累积相同的对象

Question

        ComparisonResults comparisonResults = requestsList
                .parallelStream()
                .map(item -> getResponse(item))
                .map(item -> compareToBl(item))
                .reduce(new ComparisonResults(), (result1, result2) ->
                {
                    result1.addSingleResult(result2);
                    return result1;
                });

什么时候

    private ComparisonResults compareToBl(CompleteRoutingResponseShort completeRoutingResponseShortFresh) {
...

        ComparisonResults comparisonResults = new ComparisonResults();
...
            return comparisonResults;
}

但是当我调试时：

 .reduce(new ComparisonResults(), (result1, result2) ->
                    {
                        result1.addSingleResult(result2);
                        return result1;
                    });

我看到 result1 和 result2 总是同一个对象（对象 id 在 想法）

result1 等于 result2

Answer 1

addSingleResult 应该返回一个新对象作为 this 的修改副本，因此您应该将代码更改为：

.reduce(new ComparisonResults(), (result1, result2) ->
                {
                    return result1.addSingleResult(result2);
                });

否则，您总是返回相同的实例（没有修改）。

来自Java documentation：

reduce 操作总是返回一个新值。然而 累加器函数每次处理时也会返回一个新值 流的一个元素。假设你想减少元素 将流转换为更复杂的对象，例如集合。这有可能 阻碍您的应用程序的性能。如果你的减少操作 涉及将元素添加到集合中，然后每次您的 累加器函数处理一个元素，它创建一个新集合 包括元素，这是低效的。会更多 相反，您可以有效地更新现有集合。你可以做 这与 Stream.collect 方法一起使用，下一节将对此进行介绍。