在Java 8中,Stream有一种减少方法:
T reduce(T identity, BinaryOperator<T> accumulator);
是否允许累加器运算符修改其两个参数之一?我猜不是因为JavaDoc说累加器应该是NonInterfering,尽管所有示例都提到修改集合,而不是修改集合的元素。
因此,举一个具体的例子,如果我们有
integers.reduce(0, Integer::sum);
并假设暂时Integer是可变的,是否sum可以通过向其添加第二个参数的值来修改其第一个参数?
Integer
sum
我猜不是,但是我也想举个例子说明这种干扰会引起什么问题。
否。累加器不应修改其自变量。它接受两个值并产生一个新值。如果要在累积过程中使用突变(例如,将字符串累积到StringBuffer中而不是进行串联),请使用Stream.collect()专为此目的而设计的。
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 + b和0 + c + d,然后将结果相加。但是,如果它们共享相同的标识值,并且由于其中一项计算而导致该值发生了变异,则其他计算可能会从错误的值开始。
0 + a + b
0 + c + d
(还要注意,如果实现值得,即使对于顺序计算,也可以允许该实现执行此操作。)