多进程_父进程子进程数据传递共享

进程queue传递
from multiprocessing import Process,Queue

def f(qq):
    qq.put([42, None, 'hello'])

if __name__ == '__main__':
    q = Queue() #父进程queue
    p = Process(target=f,args=(q,)) #子进程 父进程的queue传给子进程 实现数据传递
    p.start() #启动子进程
    print(q.get())  # prints "[42, None, 'hello']" 父进程q可以get到子进程p 实现父进程子进程数据共享
    p.join()

#线程queue不能传给进程

管道传递
 from multiprocessing import Process, Pipe
 
 def f(conn):
     conn.send([42, None, 'hello from child'])
     conn.send([43,None,'hello from child2'])
     print("child recv:",conn.recv())
     conn.close()
 
 if __name__ == '__main__':
     parent_conn, child_conn = Pipe() #生成管道实例，取出两端
     p = Process(target=f, args=(child_conn,))
     p.start()
     print(parent_conn.recv())# prints "[42, None, 'hello']"
     print(parent_conn.recv())
     parent_conn.send("hello send by parent")
     p.join()

manager数据共享
 from multiprocessing import Process, Manager
 import os
 
 def f(d, l):#每个子进程执行的函数
     d[os.getpid()]=os.getpid()
     l.append(os.getpid())
     print(l)
 
 
 if __name__ == '__main__':
     with Manager() as manager:#
         d = manager.dict() #父进程生成一个字典 多个进程之间可共享的字典
 
         l = manager.list(range(5)) #父进程生成一个列表 多个进程之间可以共享的列表 默认有5个数据
         p_list = [] #用于多个进程join
         for i in range(10):
             p = Process(target=f, args=(d, l))
             p.start() #开启10个子进程
             p_list.append(p)
         for res in p_list: # 等待每个子进程结果
             res.join()
 
         print(d)
         print(l)