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

如何解决与 ConcurrentSkipListSet 一起正常工作的动态比较器

我正在尝试使用

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

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

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

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

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

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

解决方法

所有并发集合都在元素放置和元素获取之间建立了发生之前的关系。

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

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

从add()到pollFirst()有一个happens-before关系，所以在调用add()的线程中创建的对象对调用pollFirst()的线程是可见的。>

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