基于时间的线程安全优先级队列

我需要一些类似队列的数据结构来执行以下任务：

1. 有些线程添加了附加延迟值的数据项(例如秒)，例如queue.add(data, delay)。
2. 既可以有不同的延迟，也可以有相同的延迟，队列应充当优先队列：延迟越小的项越接近末尾(出队速度更快)
3. 排队项每秒钟delay应减1，直到达到0(然后保持不变为0)
4. 在delay为0的项目中，出列顺序就是它们的插入顺序(虽然到达0的顺序更好)
5. 一些客户端线程系统地从该队列中获取元素，并且它只提供delay = 0元素。如果不存在，则它将阻塞或引发。

因此，我想要一些队列的功能+一点调度、线程安全。我怀疑，在某些情况下，这类事情应该是一项相当常规的任务。

我的问题：对于此类任务，是否有针对java或scala的生产就绪解决方案？我不想再发明另一辆自行车了。

编辑：似乎在Java标准库中确实有这样的东西：DelayQueue，在回答之前先看一看。

---

解决方案

您可以使用应作为输入Comparable对象的PriorityQueue。 您应该基于Timestamp字段比较这些对象(越小越好)；正如@Henry已经提到的，存储Timestamp比存储delay更好。这非常容易实现；只需存储currentTime + delay。

然后，当客户端请求head元素时，您需要创建一个synchronized方法，该方法执行以下操作：

• 首先peek()检查head元素是否有timestamp < currentTime
• 如果是，poll()这个元素，否则抛出。

---

第二个解决方案(移植自我的评论)：

实际上，可以添加一个ScheduledThreadPoolExecutor作为中间层； 现在您不需要Timestamp，只需将delay提供给Executor。

当每个runnable/callable执行时，相应的对象被添加到另一个正常的FIFO队列，在那里它将立即可用于轮询；

您的客户端现在可以轮询第二个FIFO队列中的元素。