Python进程间通信Pipe无法收到消息:子进程如何正确接收管道文件描述符?
python进程间通信pipe无法收到消息的原因
在使用python的管道(pipe)进行进程间通信时,如果父进程无法收到子进程消息,可能是由于参数传递问题。
代码中,在创建子进程时,没有正确地将管道文件描述符传递给子进程。子进程需要管道的一端才能向其写入信息,而父进程需要另一端才能读取消息。
为了解决这个问题,需要修改子进程的创建代码,将管道文件描述符作为参数传递给子进程:
import os import time from multiprocessing import Pipe, Process fd1, fd2 = Pipe() def fun(name, fd): time.sleep(3) # 向管道写入内容 fd.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()
通过将管道文件描述符传递给子进程,子进程能够向管道写入信息,父进程可以读取这些信息。
以上就是Python进程间通信Pipe无法收到消息:子进程如何正确接收管道文件描述符?的详细内容,更多请关注硕下网其它相关文章!