Python进程间通信使用Pipe无法收到消息？

Z时代
2024-02-23
分类：IT

最近在学习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()