Python多进程-进程间数据的传递

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

两个进程间的数据是独立的，要进行数据传递的话可通过几个方法

Queue

通过队列来进行进程间数据的传递

# -*- coding:utf-8 -*-
__author__ = "MuT6 Sch01aR"from multiprocessing import Process, Queuedef 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, Pipedef 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()

运行结果