BlockingQueue 和 putAll

Question

有谁知道为什么java的BlockingQueue没有putAll方法？这样的方法有问题吗？有什么好的方法可以解决这个问题而不必完全重新实现 BlockingQueue 吗？

Answer 1

for (Item item : items) {
    queue.put(item);
}

3行，不确定这是否完全重新实现了阻塞队列。

我想它希望你一一放置，以防线程正在等待从中读取，它们不会等待你读完所有内容。

Answer 2

我在 ArrayBlockingQueue 中发现了同样的问题。我们想要一些缺少的附加方法：

• void putAll(Collection c)
抛出 InterruptedException
• intrainAtLeastOneTo(@OutputParam Collection c)
抛出 InterruptedException
• intrainAtLeastOneTo(@OutputParamCollectionc, int maxElements)
抛出 InterruptedException

有些人主张使用 BlockingQueue>，但这需要 malloc 列表。有时你想避免它。另外，假设您希望生产者和消费者使用相同的“块”大小。

关于排出：同样，您可能希望生产者和消费者的块大小不匹配。因此，生产者可能会插入单个项目，但消费者会批量工作。 drainTo() 不会阻塞，因此 drainAtLeastOneTo() 是一个解决方案。

最后，我们复制了ArrayBlockingQueue的默认impl并直接添加方法。同样，一个缺点是您需要对具体类型进行操作，而不是接口 BlockingQueue。

您还可以考虑使用著名的（臭名昭著的？）LMAX Disruptor，但该模型与标准 BlockingQueue 有很大不同，因为您无法控制项目何时被消耗。