有一个我试图实现的生产者和消费者。 生产者将不断将消息推入队列。 但消费者必须在到达队列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中,一旦消息在队列中可用,使用者将立即读取。
任何帮助都将不胜感激。
Java内置了delayqueue
,这是queue
的一个实现,它只在延迟周期到期后才提供元素。
请参阅本教程。