Python多进程Pipe管道阻塞：父进程接收不到子进程数据如何解决？（进程.阻塞.如何解决.管道.接收...）

Python多进程Pipe管道阻塞问题及解决方案

在Python多进程编程中，Pipe管道是常用的进程间通信方式。然而，初学者常遇到父进程无法接收子进程数据，导致程序阻塞的问题。本文分析一个典型案例，并提供解决方案。

问题描述：

以下代码尝试使用multiprocessing.Pipe实现父进程与五个子进程间的通信。子进程函数fun在3秒后发送包含进程名和ID的字典到管道。但父进程使用fd2.recv()接收数据时发生阻塞。

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

问题分析：

问题在于子进程fun函数未正确接收管道对象fd1。Process类的target函数参数列表仅包含name，缺少fd1。因此，fun函数内部fd1未定义，fd1.send()无法访问管道，数据无法发送。父进程的fd2.recv()自然阻塞。

解决方案：

将管道对象fd1作为参数传递给子进程fun函数。修改后的代码如下：

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))  # 将fd1传递给子进程
        jobs.append(p)
        p.start()
    for i in range(5):
        # 读管道
        data = fd2.recv()
        print(data)
    for i in jobs:
        i.join()

通过将fd1作为参数传递，子进程正确访问管道对象，实现进程间通信。修改后的代码可正常运行，父进程成功接收子进程消息。 注意，我们也修正了process为Process以及pipe为Pipe的小写错误。

以上就是Python多进程Pipe管道阻塞：父进程接收不到子进程数据如何解决？的详细内容，更多请关注知识资源分享宝库其它相关文章！