Python中如何使用进程管道（Pipe）和进程管理器（Manager）实现进程间通信？

本文共计806个文字，预计阅读时间需要4分钟。

进程间通过管道通信是不安全的。下面是简化后的内容：

进程间使用 `Pipe` 通信。`from multiprocessing import Pipe, con1, con2=Pipe()` 管道用于多进程间的信息传递。一个进程是 `con1` 接收数据，另一个进程是 `con2` 发送数据。

进程管道 Pipe

管道之间通信是不安全的

from multiprocessing import Pipe

con1,con2 = Pipe()

管道是用于多进程之间通信的一种方式。如果在单进程中使用管道，那么就是con1收数据，就是con2发数据。如果是con1发数据，就是con2收数据如果在多进程中使用管道，那么就必须是父进程使用con1收，子进程就必须使用con2发

父进程使用con1发，子进程就必须使用con2收

父进程使用con2收，子进程就必须使用con1发

父进程使用con2发，子进程就必须使用con1收

在管道中有一个著名的错误叫做EOFError。是指，父进程中如果关闭了发送端，子进程还继续接收数据，那么就会引发EOFError。

from multiprocessing import Pipe, Process


def func(con):
con1, con2 = con
con1.close() # 子进程使用con2和父进程通信，所以
while 1:
try:
print(con2.recv()) # 当主进程的con1发数据时，子进程要死循环的去接收。
except EOFError: # 如果主进程的con1发完数据并关闭con1，子进程的con2继续接收时，就会报错，使用try的方式，获取错误
con2.close() # 获取到错误，就是指子进程已经把管道中所有数据都接收完了，所以用这种方式去关闭管道
break


if __name__ == '__main__':
con1, con2 = Pipe()
p = Process(target=func, args=((con1, con2),))
p.start()
con2.close() # 在父进程中，使用con1去和子进程通信，所以不需要con2，就提前关闭
for i in range(10): # 生产数据
con1.send(i) # 给子进程的con2发送数据
con1.close() # 生产完数据，关闭父进程这一端的管道

结果：

0
1
2
3
4
5
6
7
8
9

例

from multiprocessing import Process, Pipe


def f(conn):
conn.send([42, None, 'hello fromchild'])
conn.send([42, None, 'hello fromchild2'])
print("from parent:", 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("范冰冰")

结果：

[42, None, 'hello fromchild']
[42, None, 'hello fromchild2']
from

parent_conn, child_conn = Pipe()生成管道实例，相当于socket通信，一头在主进程，一头在子进程，就可以实现进程之间的数据的传递

进程 Manager

Queue，Pipe只能实现进程之间数据的传递，Manager可以进行数据之间的共享

from multiprocessing import Manager, Value

m = Manager()
num = m.dict({键: 值})
num = m.list([1, 2, 3])

例

from multiprocessing import Process, Manager


def func(num):
num[0] -= 1 # num[0] = 1
print('子进程中的num的值是', num)


if __name__ == '__main__':
m = Manager()
num = m.list([1, 2, 3])
p = Process(target=func, args=(num,))
p.start()
p.join()
print('父进程中的num的值是', num)

结果：

子进程中的num的值是 [0, 2, 3]
父进程中的num的值是 [0, 2, 3]