我正在寻找并发队列的现有实现,该实现可用于实现典型的生产者-消费者模式,但需要注意以下几点。每个生产者都是短暂的,但在退出之前必须阻塞,直到它放在队列上的所有消息都被消费者处理完。消费者和队列是长期存在的。
我的一些想法是,要么使用单个分区队列,其中每个分区被分配给一个生产者,要么为每个生产者建立一个专用队列,并在生产者队列之上构建一种复合队列,供消费者使用。
这似乎是http服务器的常见模式,它有许多http线程和固定数量的工作线程,前者充当队列的生产者,后者充当队列的消费者。然后,在将http响应返回给http客户端之前,http威胁将被阻塞,直到它入队的工作被消费者完全处理为止。
https://stackoverflow.com/questions/52796315
复制相似问题