如果使用时 ConcurrentMap 中不存在新元素，如何添加新元素

Question

我正在使用线程进行 Java 开发，但事实是我没有太多想法。事情比我想象的要复杂。

问题是我必须将多个对象分组到 ConcurrentMap 中，如果该对象不在 ConcurrentMap 中，则必须添加它，否则修改它。

对于修改数据的部分，我没有问题，但是当我想更新时，我收到“递归更新”错误，我不知道我还能做什么来修改/添加我的 ConcurrentMap 并使其线程安全。

private final ConcurrentMap<String, Person> myData= new ConcurrentHashMap<>();

private void processMyData(){

 myData.compute(String, (key, person) -> {
        if (person== null) {
            myData.putIfAbsent(key, new Person("Antonio", 0, false));
        } else {
            //Update data, this part its ok!
            person.setConnectedHours(person.getConnectedHours() + 1000);
        }
        return person;
    });

}   

Answer 1

如果该键不存在，您只需创建一个新的 person 对象并返回它。 ConcurrentMap#Compute 将确保整个调用是原子的。
如果在compute中不存在key时调用putIfAbsent，则会导致无限循环。 （无限循环发生在ConcurrentHashMap#putVal方法中）。

        myData.compute("A", (key, person) -> {
            if (person== null) {
                person = new Person();
            } else {
                //Update data, this part its ok!

            }
            return person;
        });

请参阅 ConcurrentMap#compute JDK 文档：

尝试计算指定键及其当前映射值的映射（如果没有当前映射，则为 null）。例如，要创建字符串消息或将其附加到值映射：
map.compute(key, (k, v) -> (v == null) ? msg : v.concat(msg))

Answer 2

我昨晚找到了解决方案，但我忘了回复这张​​票。

我意识到在一个新项目中做了一些非常简单的测试，当我应用一个简单的 lambda ex 时，我可以进行 put： (k,val) -> v == 空？ " new text" : "modify"

然后，我只是看到当我生成新对象时我没有执行返回，所以它不是实例。

一个初学者的错误呵呵，但我希望它可以对和我有同样错误的人有所帮助:)

问候！

    private final ConcurrentMap<String, Person> myData= new ConcurrentHashMap<>();
    
    private void processMyData(){
    
     myData.compute(String, (key, person) -> {
            if (person== null) {
                return new Person("Antonio", 0, false);
            } else {
                //Update data, this part its ok!
                person.setConnectedHours(person.getConnectedHours() + 1000);
                return person;
            }
            
        });
    
    }