Python多进程Pipe管道阻塞：父进程接收不到子进程消息怎么办？-Python教程-PHP中文网

Python多进程Pipe管道阻塞：父进程接收不到子进程消息怎么办？

聖光之護

发布： 2025-03-05 11:06:25

原创

929人浏览过

python多进程pipe管道阻塞：父进程接收不到子进程消息怎么办？

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

在Python多进程编程中，Pipe管道是常用的进程间通信方式。然而，父进程有时无法从管道接收子进程发送的消息，导致程序阻塞。本文分析一个典型案例并提供解决方案。

问题描述：

以下代码片段使用multiprocessing.Pipe实现父进程和子进程间的通信。子进程休眠3秒后，向管道发送包含进程名称和ID的字典。但父进程的fd2.recv()方法阻塞，无法接收消息。

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

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()

登录后复制

问题根源：

豆包AI编程

豆包推出的AI编程助手

483

查看详情

问题在于子进程fun函数未能正确访问管道对象。fd1和fd2由父进程创建，子进程无法直接使用。

解决方案：

将管道对象fd1作为参数传递给子进程：

p = Process(target=fun, args=(i, fd1))

登录后复制

完整修改后的代码：

import os
import time
from multiprocessing import Pipe, Process

fd1, fd2 = Pipe()


def fun(name, pipe):
    time.sleep(3)
    pipe.send({name: os.getpid()})


if __name__ == "__main__":
    jobs = []
    for i in range(5):
        p = Process(target=fun, args=(i, fd1))
        jobs.append(p)
        p.start()
    for i in range(5):
        data = fd2.recv()
        print(data)
    for i in jobs:
        i.join()

登录后复制

通过将fd1作为参数传递，子进程可以正确使用管道发送消息，解决父进程阻塞问题。现在父进程能够成功接收子进程发送的消息。

以上就是Python多进程Pipe管道阻塞：父进程接收不到子进程消息怎么办？的详细内容，更多请关注php中文网其它相关文章！