读取Java中已有10分钟的消息

问题描述 投票:0回答:1

[我正在尝试实现一个生产者和消费者。生产者将继续将消息推入队列的地方。但是,尽管消费者必须在到达队列后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中,使用者将在队列中有消息时立即阅读。

任何帮助将不胜感激。

[我正在尝试实现一个生产者和消费者。生产者将继续将消息推入队列的地方。但是,尽管消费者只需要在30分钟后阅读这些消息即可...

java queue blockingqueue
1个回答
0
投票

DelayQueue

© www.soinside.com 2019 - 2024. All rights reserved.