最近在学习python,使用管道Pipe在两个进程间通信。为啥父进程无法收到消息
如下代码,读管道无法读取到消息,且阻塞的样子。为什么会这样?
import os
import time
from multiprocessing import Pipe, Process
fd1, fd2 = Pipe()
def fun(name):
time.sleep(3)
# 向管道写入内容
fd1.send({name: os.getpid()})
if __name__ == "__main__":
jobs = []
for i in range(5):
p = Process(target=fun, args=(i,))
jobs.append(p)
p.start()
for i in range(5):
# 读管道
data = fd2.recv()
print(data)
for i in jobs:
i.join()
p = Process(target=fun, args=(i, fd1))
把参数传上