Python多進程-進程間數據的傳遞

兩個進程間的數據是獨立的，要進行數據傳遞的話可通過幾個方法

Queue

通過隊列來進行進程間數據的傳遞

# -*- coding:utf-8 -*-
__author__ = "MuT6 Sch01aR"

from multiprocessing import Process, Queue

def Child_Process(n):
    n.put("Data From Child Process")

if __name__ == '__main__':
    q = Queue()
    p = Process(target=Child_Process, args=(q,))
    p.start()
    print(q.get())
    p.join()

 運行結果

父進程中聲明了一個queue，也生成了一個子進程，然后父進程把queue克隆一份，然后通過pickle序列化queue，再把queue進行pickle反序列化傳入子進程

兩個進程之間通過進程queue進行數據傳遞需要經過pickle的序列化和反序列化

Pipe

通過管道來進行進程間數據的傳遞

# -*- coding:utf-8 -*-
__author__ = "MuT6 Sch01aR"

from multiprocessing import Process, Pipe

def f(conn):
    conn.send("Data_1 from Conn_1")
    conn.send("Data_2 from Conn_1")
    print("Conn_1: ",conn.recv())
    conn.close()

if __name__ == '__main__':
    conn_1, conn_2 = Pipe() #生成管道的兩邊，分別傳給兩個進程
    p = Process(target=f, args=(conn_1,))
    p.start()
    print("Conn_2: ",conn_2.recv())
    print("Conn_2: ",conn_2.recv())
    conn_2.send("Data_1 from Conn_2")
    p.join()

 運行結果

上面是兩邊的管道收發數據的次數一樣，如果把conn_2給conn_1發送數據的那一行代碼去掉

腳本就會在conn_1接收數據處一直等着