问Java:具有长生命周期消费者和短生命周期生产者的处理保证的并发队列

EN

我正在寻找并发队列的现有实现，该实现可用于实现典型的生产者-消费者模式，但需要注意以下几点。每个生产者都是短暂的，但在退出之前必须阻塞，直到它放在队列上的所有消息都被消费者处理完。消费者和队列是长期存在的。

我的一些想法是，要么使用单个分区队列，其中每个分区被分配给一个生产者，要么为每个生产者建立一个专用队列，并在生产者队列之上构建一种复合队列，供消费者使用。

这似乎是http服务器的常见模式，它有许多http线程和固定数量的工作线程，前者充当队列的生产者，后者充当队列的消费者。然后，在将http响应返回给http客户端之前，http威胁将被阻塞，直到它入队的工作被消费者完全处理为止。