您可以做的一个技巧是让队列排队。因此，您要做的是只有一个阻塞队列，所有线程都订阅该队列。然后，当您将某些内容排队到其中一个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。我不确定该策略的价值如何，但是它确实可以实现您想要的。