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

最近在学习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()
阅读 1.6k
1 个回答

p = Process(target=fun, args=(i, fd1)) 把参数传上

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题