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

Posted Sch01aR#

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了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接收数据处一直等着

 

以上是关于Python多进程-进程间数据的传递的主要内容,如果未能解决你的问题,请参考以下文章

在 Python 多处理进程中运行较慢的 OpenCV 代码片段

python线程间通信的问题,回答有加分!300

Python 3 并发编程多进程之队列(推荐使用)

python并发编程:多进程-队列

python学习笔记——多进程中共享内存Value & Array

Python之路,day11-Python基础