我有一个带有一堆进程的 Multiprocessing 应用程序,我希望控制线程向多个进程广播消息。如果我为每个使用一对管道,将会有大量管道。
有没有办法同时向多个进程发送一条消息?
回答1
我认为这取决于您发送消息的实际目的是什么:
- 如果目的是在进程之间共享 value/values,则可以使用
multiprocessing.Value
或multiprocessing.Array
- 如果目的是同步某些处理的下一阶段,您可以使用
multiprocessing
Barrier
或Event
- 如果您真的想对大量消息进行“发布/订阅”,您可能希望使用来自 Redis 的发布/订阅或带有
mosquitto
代理的 MQTT。