微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

并发散列映射中值的原子更新 - 如何?

如何解决并发散列映射中值的原子更新 - 如何?

任务是跟踪一些正在运行的进程。将该信息保存在内存中很好,所以我使用并发散列映射来存储该数据:

ConcurrentHashMap<String,ProcessMetaData> RUNNING_PROCESSES = new ConcurrentHashMap();

安全地将新对象放入地图中一切都很好,问题是这些进程的状态会发生变化,因此我必须不时更新 ProcessMetaData。我使 ProcessMetaData 不可变并使用 ConcurrentHashMapcompute() 方法更新值,但现在问题是 ProcessMetaData 变得更加复杂并且保持它不可变变得难以管理。问题是 - 只要我只更新原子中的 ProcessMetaData (根据 javadoc)compute() 方法 - 对象可能是可变的,并且总体上仍然是线程安全的?我的假设正确吗?

解决方法

只要您只访问传递给 compute 的函数内的值,在该函数中所做的修改就是安全的。

然而,这是一个毫无意义的理论观点。将值存储到集合或映射中的目的是最终检索和使用它们。这就是问题开始的地方。

compute 方法返回结果值,就像 get 返回当前存储的值一样。一旦调用者开始使用该值,此使用可能与地图上的后续 compute 操作并发。 get 方法甚至可以在 compute 操作正在进行时检索该值。允许非阻塞检索操作是ConcurrentHashMap的主要功能之一。因此,可能会出现各种竞争条件。

因此,当您将映射用作只写内存时,使用可变对象并修改已存储在 compute 中的值是安全的,这是一个牵强的场景。当您使用不同的线程安全机制来确保在开始读取地图之前已完成所有更新时,它可能会起作用,但您的用例似乎有所不同。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。