进程间通信
程序员文章站
2022-07-09 19:31:11
一、通过Queue方式进行通信 1 from multiprocessing import Process,Queue,Pipe 2 def f(q): 3 q.put([42,2,'hello']) 4 5 if __name__=='__main__': 6 q=Queue() 7 p_list ......
一、通过queue方式进行通信
1 from multiprocessing import process,queue,pipe 2 def f(q): 3 q.put([42,2,'hello']) 4 5 if __name__=='__main__': 6 q=queue() 7 p_list=[] 8 9 for i in range(3): 10 p=process(target=f,args=(q,)) 11 p_list.append(p) 12 p.start() 13 14 print(q.get()) 15 print(q.get()) 16 print(q.get())
二、通过pipe方式通信
1 def f(conn): 2 conn.send([42,none,'hello']) 3 conn.send('love') 4 print(conn.recv()) 5 conn.close() 6 if __name__=='__main__': 7 parent_conn,child_conn=pipe() 8 p=process(target=f,args=(child_conn,)) 9 p.start() 10 print(parent_conn.recv()) 11 print(parent_conn.recv()) 12 parent_conn.send('你好') 13 p.join()
上一篇: 2020年应该如何学习前端开发
下一篇: vue实现首页导航面板组件