快速澄清,请的Java -BlockingQueue - 多生产,单次消费
我知道BlockingQueues
是线程安全的。
这是否意味着我可以通过一个单一的参照阻塞队列谁可以不管三七二十一丢弃事件所有的生产者由单个消费者消费,并没有被破坏?
否则不得不产生多达20 BlockingQueues
可能或不可能定期更新,并以任何效率阅读它们似乎是一项难以克服的任务。
快速澄清,请的Java -BlockingQueue - 多生产,单次消费
我知道BlockingQueues
是线程安全的。
这是否意味着我可以通过一个单一的参照阻塞队列谁可以不管三七二十一丢弃事件所有的生产者由单个消费者消费,并没有被破坏?
否则不得不产生多达20 BlockingQueues
可能或不可能定期更新,并以任何效率阅读它们似乎是一项难以克服的任务。
这是否意味着我可以将阻塞队列的单个引用传递给所有可以将事件放在一个消费者中并且不会中断的生产者?
一句话,是的。这是安全的。引用documentation:
BlockingQueue
实现是线程安全的。所有排队方法都使用内部锁或其他形式的并发控制自动实现其效果。
精彩。它似乎工作,但我不想在一年后遇到问题。 – Sheriff