考虑一个BlockingQueue
和一些等待的线程poll(long, TimeUnit)
(也可能在take()
).
现在队列是空的,需要通知等待线程它们可以停止等待。预期的行为是null
退回或申报的InterruptedException
thrown.
Object.notify()
不会为LinkedBlockingQueue
因为线程正在等待内部锁。
有什么直接的方法吗?
BlockingQueue 的 Javadoc 提出了一个好方法:
BlockingQueue 本质上并不
支持任何类型的“关闭”或
“关机”操作表明
将不会添加更多项目。需求
这些功能的使用往往是
取决于实施。例如,
生产者的一个常见策略是
插入特殊的流尾或毒药
被解释的对象
消费者采取相应措施时。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)