Java 8中的reduce累加器是否可以修改其参数?


问题内容

在Java 8中,Stream有一种减少方法:

T reduce(T identity, BinaryOperator<T> accumulator);

是否允许累加器运算符修改其两个参数之一?我猜不是因为JavaDoc说累加器应该是NonInterfering,尽管所有示例都提到修改集合,而不是修改集合的元素。

因此,举一个具体的例子,如果我们有

 integers.reduce(0, Integer::sum);

并假设暂时Integer是可变的,是否sum可以通过向其添加第二个参数的值来修改其第一个参数?

我猜不是,但是我也想举个例子说明这种干扰会引起什么问题。


问题答案:

否。累加器不应修改其自变量。它接受两个值并产生一个新值。如果要在累积过程中使用突变(例如,将字符串累积到StringBuffer中而不是进行串联),请使用Stream.collect()专为此目的而设计的。

这是一个代码示例,如果您尝试这样做会产生错误的答案。假设您要对假设的MutableInteger类进行加法:

// Don't do this
MutableInteger result = stream.reduce(new MutableInteger(0), (a,b) -> a.add(b.get()));

得出错误答案的原因之一是,如果我们并行拆分计算,则现在两个计算共享相同的可变起始值。注意:

a + b + c + d
= 0 + a + b + 0 + c + d  // 0 denotes identity
= (0 + a + b) + (0 + c + d) // associativity

因此我们可以自由拆分流,计算和的0 + a + b0 + c + d,然后将结果相加。但是,如果它们共享相同的标识值,并且由于其中一项计算而导致该值发生了变异,则其他计算可能会从错误的值开始。

(还要注意,如果实现值得,即使对于顺序计算,也可以允许该实现执行此操作。)