多个阻止队列，单个使用者

Question

我有多个包含要发送的消息的BlockingQueues。消费者数量可能少于队列数量吗？我不想遍历队列并继续轮询它们（忙于等待），并且我不想为每个队列都分配一个线程。相反，当任何队列中都有消息可用时，我想唤醒一个线程。

Answer 1

您可以做的一个技巧是让队列排队。因此，您要做的是只有一个阻塞队列，所有线程都订阅该队列。然后，当您将某些内容排队到其中一个BlockingQueues中时，您还将排队队列也排队到了该单个队列中。因此，您将获得以下内容：

BlockingQueue<WorkItem> producers[] = new BlockingQueue<WorkItem>[NUM_PRODUCERS];
BlockingQueue<BlockingQueue<WorkItem>> producerProducer = new BlockingQueue<BlockingQueue<WorkItem>>();

然后，当您获得一个新的工作项目时：

void addWorkItem(int queueIndex, WorkItem workItem) {
    assert queueIndex >= 0 && queueIndex < NUM_PRODUCERS : "Pick a valid number";
    //Note: You may want to make the two operations a single atomic operation
    producers[queueIndex].add(workItem);
    producerProducer.add(producers[queueIndex]);
}

现在，您的所有消费者都可以阻止ProducerProducer。我不确定该策略的价值如何，但是它确实可以实现您想要的。