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

rs75

一个进程产生数据, 然后每条数据都要传输到主进程的每个消费线程来让它们选择属于自己的,用什么方式合适?

最佳答案

月排行榜 / 总排行榜

BSOD

2020-10-9 18:43:15

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

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

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

复制代码

跳转到最佳答案楼层

lhgzbxhz

跨进程的话......想要跨平台的话只能用文件操作，但是那样可能会涉及到文件锁问题，编程难度大
如果是在windows环境下最好用内存映射文件

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的实例化一定要在入口函数后面, 否则将会报错!

rs75

BSOD 发表于 2020-10-8 23:32
那就是进程间通讯啊, 途径有很多种: 队列, 管道...
我一般喜欢使用Python自带的队列

每一份数据都要传到每个消费者, 队列管道都只能被获取一次啊

BSOD

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

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

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

复制代码