进程间通信

一、通过Queue方式进行通信

from multiprocessing import Process,Queue,Pipe
def f(q):
    q.put([42,2,'hello'])

if __name__=='__main__':
    q=Queue()
    p_list=[]

    for i in range(3):
        p=Process(target=f,args=(q,))
        p_list.append(p)
        p.start()

    print(q.get())
    print(q.get())
    print(q.get())

二、通过Pipe方式通信 

def f(conn):
    conn.send([42,None,'hello'])
    conn.send('love')
    print(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())
    print(parent_conn.recv())
    parent_conn.send('你好')
    p.join()