提问者:小点点

在Java阅读10分钟前的留言


有一个我试图实现的生产者和消费者。 生产者将不断将消息推入队列。 但消费者必须在到达队列30分钟后才能读取这些消息。

假设

m1 reaches at 10am 
m2 reaches at 10.10am
m3 reaches at 10.20am

消费者必须在

m1 at 10.30am
m2 at 10.40am
m3 at 10.50am 

在Java有什么办法。

我尝试了BlockingQueue,但我不认为我们可以使用BlockingQueue存档它。 在BlockingQueue中,一旦消息在队列中可用,使用者将立即读取。

任何帮助都将不胜感激。


共1个答案

匿名用户

Java内置了delayqueue,这是queue的一个实现,它只在延迟周期到期后才提供元素。

请参阅本教程。