java - 在 Java 的 ThreadPoolExecutor 中重新排序队列

Question

<分区>

Answer 1

getQueue()将始终返回准确的 BlockingQueue<Runnable>你传递给ThreadPoolExecutor .

文档令人担心的是，如果您不能保证 BlockingQueue 的线程安全，您很容易遇到双重运行问题。 .如果您使用 PriorityBlockingQueue , 并且只使用 remove和 add (或者更直接地说，offer)，那么你就安全了，你甚至可以直接从 getQueue() .

换句话说，每当你的信号告诉你一些Runnable的优先级已经改变，那么你应该remove它并检查删除的结果( true 如果删除)，只有当它实际被删除时，您才应该重新添加它。您不能保证在这些操作之间不会拾取某些东西，但至少可以保证您不会重复运行 Runnable。 ，如果用 contains 完成，这很容易发生-> remove -> add .

或者，您也可以编写自己的 BlockingQueue 实现使用 Comparator (如 PriorityBlockingQueue )每当被要求提供新数据时都会找到最高优先级。考虑到涉及的各种接口(interface)，这听起来像是要做更多的工作。