java - 队列中的 2 路通知

Question

我有一个典型的生产者消费者问题，唯一的区别是消费者不必处理生产者生产的每个单位。生产者完成了固定数量的数据，然后消费者应该接受它。此外，生产者应该等待消费者读取该批处理。

我为此使用 TransferQueue，但现在我希望在固定时间后我应该读取数据，即使大小很小。

通常我需要队列的两种方式通知，如何实现？

Answer 1

我建议使用两个线程。

这个想法是生产者将新数据放入您的队列中，直到达到所需的条目数量。然后它等待 (wait()) 通知 (notify())。另一方面，消费者也将等待，直到队列中有正确数量的数据，或者达到定义的超时(wait(int timeToWait))。然后它会处理数据并通知Producer进行工作。