与 ConcurrentSkipListSet 一起正常工作的动态比较器答案

【问题标题】：On-the-fly comparator that works correctly with ConcurrentSkipListSet与 ConcurrentSkipListSet 一起正常工作的动态比较器
【发布时间】：2021-04-04 11:10:33
【问题描述】：

我正在尝试使用

queue = new ConcurrentSkipListSet<Task>(Comparators.comparing(Task::priority))

作为具有唯一元素的并发优先级队列（参见类似的讨论here），但我需要不时更改任务的优先级。

很明显，改变元素的优先级当它们在集合中时就是打开一罐虫子；幸运的是，我只需要在将它们从queue 中删除之后并在重新提交它们之前更改它们的优先级。更准确地说，我使用pollFirst() 从queue 中弹出一个元素，我可能需要在更新其优先级（具有较低优先级）后重新提交。

如果这是一个串行实现，那么当元素在集合之外时更改它们的优先级应该没有问题。

在并发访问的情况下进行此更新的线程安全方式是什么？ 是否足以保证

task = queue.pollFirst() 发生在task.priorityUpdate() 之前，发生在queue.add(task) 之前？

【问题讨论】：

这听起来对我来说已经足够了——我没有看到任何缺陷。显然，另一个线程可能会取出并使用您已决定降低优先级但尚未解决的元素（但我认为这不是您要问的）。
您的标题似乎与您的实际问题不符。

标签： java multithreading concurrency happens-before concurrentskiplistmap

【解决方案1】：

所有并发集合在元素 put 和 element get 之间建立先发生关系。

问题是如果您需要在他们在队列中时更改优先级，然后将他们取出并放回，因为这是唯一的方法；然后，并发线程可能会同时放置相同的元素，然后您将丢失您的修改。在这种情况下，需要进一步同步。

但是，如果您要取出元素，更改它们的优先级，然后才评估是否应该将它们放回原处，并发集合的发生前发生保证足以确保正确性，您无需执行任何其他操作。

从add() 到pollFirst() 存在happens-before 关系，因此调用add() 的线程中创建的对象对调用pollFirst() 的线程可见。

从pollFirst() 到add() 没有。但是，如果您更改优先级，然后从同一线程调用 add()，则不需要进一步的内存限制。
如果你稍后从另一个线程调用pollFirst()，add() 和pollFirst() 之间的happens-before 关系将保证在调用add() 之前对对象的更新是可见的。

【讨论】：