我正在寻找一个Python类(最好是标准语言的一部分,而不是第三方库),来管理异步“广播式”消息。
我将有一个线程将消息放入队列中(“putMessageOnQueue”方法不能阻塞),然后多个其他线程将等待消息,预计调用一些阻塞的“waitForMessage”函数。当一个消息被放置在队列中时,我希望每个等待的线程都能得到自己的消息副本。
我已经查看了内置的Queue
类,但我认为这并不适合,因为消费消息似乎涉及从队列中移除它们,所以只有1个客户端线程会看到每个消息。
这似乎应该是一个常见的用例,有人可以推荐一个解决方案吗?