对对象流中的每个字段求和

Question

我想创建对象MyObject的实例，其中的每个字段都是该字段值的总和

我创建一个对象

       public class MyObject{
           int value;
           double length;
           float temperature;

           MyObject(int value, double length, float temperature){
               this.value = value;
               this.length = length
               this.temperature = temperature
           }
        }

然后我构建对象列表：

    List<MyObject> list = new ArrayList<MyObject>{{
          add(new MyObject(1, 1d, 1.0f));
          add(new MyObject(2, 2d, 2.0f));
          add(new MyObject(3, 3d, 3.0f));
    }}

我想要创建对象（new MyObject（6,6d，6f））

很容易对每个流求和一个字段：

Integer totalValue = myObjects.parallelStream().mapToInt(myObject -> myObject.getValue()).sum(); //returns 6;

或

Double totalLength = myObjects.parallelStream().mapToDouble(MyObject::getLength).sum(); //returns 6d

然后构造对象新的MyObject（总值、总长度、总温度）

但我能把一个流中的所有字段相加吗？我想让stream回来

new MyObject(6, 6d, 6.0f)




Answer 1

你可以试试下面这样的

MyObject me = new MyObject(
    list.stream().mapToInt(MyObject::getValue).sum(),
    list.stream().mapToDouble(MyObject::getLength).sum(),
    (float)list.stream().mapToDouble(MyObject::getTemperature).sum());

这会满足你的需要。你也可以使用Stream。减少做同样的事情。

Answer 2

它是reduce方法的直接应用：

Stream.of(new MyObject(1, 1d, 1.0f), new MyObject(2, 2d, 2.0f), new MyObject(3, 3d, 3.0f)).
                reduce((a, b) -> new MyObject(a.value + b.value, a.length + b.length, a.temperature + b.temperature))

Answer 3

其他解决方案是有效的，但它们都会产生不必要的开销；一个是通过多次复制MyObject，另一个是通过多次流式传输集合。如果MyObject是可变的，理想的解决方案是使用collect（）进行可变的缩减：

// This is used as both the accumulator and combiner,
// since MyObject is both the element type and result type
BiConsumer<MyObject, MyObject> reducer = (o1, o2) -> {
    o1.setValue(o1.getValue() + o2.getValue());
    o1.setLength(o1.getLength() + o2.getLength());
    o1.setTemperature(o1.getTemperature() + o2.getTemperature());
}
MyObject totals = list.stream()
        .collect(() -> new MyObject(0, 0d, 0f), reducer, reducer);

这个解决方案只创建一个额外的MyObject实例，并且只迭代列表一次。