python - 向多个 Multiprocessing 进程广播消息

我有一个带有一堆进程的 Multiprocessing 应用程序,我希望控制线程向多个进程广播消息。如果我为每个使用一对管道,将会有大量管道。

有没有办法同时向多个进程发送一条消息?

回答1

我认为这取决于您发送消息的实际目的是什么:

  • 如果目的是在进程之间共享 value/values,则可以使用 multiprocessing.Valuemultiprocessing.Array
  • 如果目的是同步某些处理的下一阶段,您可以使用 multiprocessing BarrierEvent
  • 如果您真的想对大量消息进行“发布/订阅”,您可能希望使用来自 Redis 的发布/订阅或带有 mosquitto 代理的 MQTT。

相似文章

随机推荐

最新文章