进程间通信

一、通过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())

View Code

二、通过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()

View Code