[我正在尝试实现一个生产者和消费者。生产者将继续将消息推入队列的地方。但是,尽管消费者必须在到达队列后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分钟后阅读这些消息即可...
DelayQueue