请快速澄清一下
我知道 BlockingQueues
是线程安全的。
这是否意味着我可以向所有生产者传递单个阻塞队列的引用,让他们随意丢弃事件,以供单个消费者消耗,而不会有任何干扰呢?
否则,生产多达20个可能或可能没有定期更新的 BlockingQueues
并以任何有效的方式读取它们,似乎是一项不可克服的任务。
请快速澄清一下
我知道 BlockingQueues
是线程安全的。
这是否意味着我可以向所有生产者传递单个阻塞队列的引用,让他们随意丢弃事件,以供单个消费者消耗,而不会有任何干扰呢?
否则,生产多达20个可能或可能没有定期更新的 BlockingQueues
并以任何有效的方式读取它们,似乎是一项不可克服的任务。
如果它是线程安全的,那就意味着你只需要一个实例队列,所有线程都可以访问。并发数据结构管理这些访问。
这也意味着你无需进行同步操作。