Python多进程Pipe管道阻塞：如何解决子进程无法向父进程发送消息的问题？

Python多进程通信：Pipe管道阻塞及解决方案

在Python多进程编程中，进程间通信至关重要。Pipe管道提供了一种便捷的进程间数据传输机制，但实际应用中可能遇到阻塞问题，例如父进程无法接收子进程发送的消息。本文分析一个典型案例，并提供解决方案。

问题描述：

以下代码尝试使用Pipe管道在父进程和多个子进程间通信。子进程运行一段时间后，向管道发送包含进程名称和ID的字典。然而，父进程接收消息时发生阻塞。

立即学习“Python免费学习笔记（深入）”；

import osimport timefrom multiprocessing import pipe, Processfd1, 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()

登录后复制