进程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)亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
