[已解决]多进程怎么一对多传递数据

BSOD

那就是进程间通讯啊, 途径有很多种: 队列, 管道...
我一般喜欢使用Python自带的队列

1. from multiprocessing import Manager
   
2. 
   
3. queue = Manager().Queue()
   
4. 
   
5. def one_process():
   
6.     queue.put("something")
   
7.    
   
8. def other_process():
   
9.     data = queue.get()

复制代码

友情提示: 我的代码只是简化的, 不要直接使用,  一定要注意的是如果在windows平台时, Queue的实例化一定要在入口函数后面, 否则将会报错!

BSOD

rs75 发表于 2020-10-9 11:18
每一份数据都要传到每个消费者, 队列管道都只能被获取一次啊

那还不简单使用`Manager`衍生出来的其他数据类型啊, 例如: dict, array等

1. from multiprocessing import Manager
   
2. 
   
3. t_dict = Manager().dict()

复制代码