我正在寻找一个Python类(最好是标准语言的一部分,而不是第三方库)来管理异步的“广播式”消息传递。
我将有一个线程将消息放入队列(“putMessageOnQueue”方法不能阻塞),然后有多个其他线程都将等待消息,它们可能调用了一些阻塞的“waitFormMessage”函数。当一条消息被放到队列中时,我希望每个等待的线程都得到它自己的消息副本。
我已经看过内置的Queue
类,但我不认为这是合适的,因为消费消息似乎需要将它们从队列中删除,因此每个消息只有一个客户端线程可以看到。
这似乎是一个常见的用例,有人能推荐一个解决方案吗?
Tags:
我认为这是一个更直接的示例(取自Python Lib中的队列示例)
我认为典型的方法是为每个线程使用一个单独的消息队列,并将消息推送到之前注册了接收此类消息的兴趣的每个队列上。
像这样的东西应该有用,但它是未经测试的代码。。。
相关问题 更多 >
编程相关推荐