17

在 Java 8 中，Stream 有一个方法 reduce：

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

累加器运算符是否允许修改其任何一个参数？我认为不是，因为 JavaDoc 说累加器应该是 NonInterfering，尽管所有示例都谈到修改集合，而不是修改集合的元素。

所以，举个具体的例子，如果我们有

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

并假设有一段时间Integer是可变的，是否sum可以通过（就地）添加第二个参数的值来修改它的第一个参数？

我想不会，但我也想举个例子说明这种干扰导致问题的地方。

4

2 回答 2

13

不，累加器不应该修改它的参数；它接受两个值并产生一个新值。如果您想在累积过程中使用突变（例如，将字符串累积到 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 + b和0 + c + d，然后将结果相加。但是，如果它们共享相同的标识值，并且该值由于其中一个计算而发生变异，则另一个可能以错误的值开始。

（进一步注意，即使对于顺序计算，实现也可以这样做，如果它认为这是值得的。）

于 2014-05-26T12:58:27.060 回答
0

这在语法上是允许的，但我认为它违背了设计模式并且是一个坏主意。

  static void accumulatorTest() {
     ArrayList<Point> points = new ArrayList<>();
     points.add(new Point(5, 6));
     points.add(new Point(0, 6));
     points.add(new Point(1, 9));
     points.add(new Point(4, 16));
     BinaryOperator<Point> sumPoints = new BinaryOperator<Point>() {
        public Point apply(Point p1, Point p2) {
           p2.x += p1.x;
           p2.y += p1.y;
           return new Point(p2); //return p2 and the list is transformed into running total
        }
     };
     Point sum = points.stream().reduce(new Point(0, 0), sumPoints); 
     System.out.println(sum);
     System.out.println(points);
  }

答案是正确的；我们得到所有 x 和 y 坐标的总和。原始列表已修改，由输出确认：

java.awt.Point[x=10,y=37] [java.awt.Point[x=5,y=6], java.awt.Point[x=5,y=12], java.awt.Point [x=6,y=21], java.awt.Point[x=10,y=37]]

于 2014-05-26T13:01:26.000 回答