问题描述
我正在尝试使用
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()
之前对对象的更新是可见的。