Collectors.Reducing方法在用作Collectors.PartitionBy的下游时更新相同的标识

Question

我有一个类似于下面myobject的类。

public class MyObject {
    private String key; // not unique. multiple objects can have the same key.
    private boolean isPermanent;
    private double value1;
    private double value2;
    
    public MyObject merge(MyObject m){
        value1 += m.getValue1();
        value2 += m.getValue2();
        return this;
    }

    // getters, setters and constructors...
}

以下是示例数据：

List<MyObject> objs = new ArrayList<>();

objs.add(new MyObject("1", false, 100, 200));
objs.add(new MyObject("2", false, 300, 100));
objs.add(new MyObject("1", false, 200, 300));

objs.add(new MyObject("3", true, 100, 200));
objs.add(new MyObject("1", true, 500, 100));
objs.add(new MyObject("1", true, 100, 100));

我想基于ispermanent和key组合这些对象，并执行了以下操作：

（注意，我添加了import static java.util.stream.collectors.*，以便在下面的代码中导入groupingby、partitioningby和reducing)

objs.stream()
    .collect(partitioningBy(MyObject::isPermanent,
                            groupingBy(MyObject::getKey,
                                       reducing(new MyObject(), MyObject::merge))));

{false : { 1 : { 300, 500 } } , { 2 : { 300, 100 } }, true : { 1 : { 600, 200 } } , { 3 : { 100, 200 } } }

但我得到的结果是：

{false : { 1 : { 1300, 1000 } } , { 2 : { 1300, 1000 } }, true : { 1 : { 1300, 1000 } } , { 3 : { 1300, 1000 } } }

由于我传递了一个对象作为标识，因此我相信每个组都更新了相同的对象。既然一个lambda不能传递到reduction方法上，那么有没有什么方法可以解决这个问题呢？

Answer 1

可以使用静态合并函数返回新实例：

public static MyObject merge(MyObject one,MyObject two) {
    MyObject merged = new MyObject ();
    merged.setValue1(one.getValue1()+two.getValue1());
    merged.setValue2(one.getValue2()+two.getValue2());
    return merged;
}

您必须删除现有的非静态merge方法，以便编译器选择静态方法来代替方法引用。

这样，MyObject::Merge每次都会生成一个新的MyObject实例。

如果不想删除现有方法，如果使用以下lambda表达式替换方法引用，则仍然可以添加statice方法：

(o1,o2)->MyObject.merge(o1,o2)

在不添加静态方法的情况下，可以使用以下lambda表达式替换MyObject::Merge方法引用：

(o1,o2)-> new MyObject().merge(o1).merge(o2)