我在用multiprocessing
包生成第二个进程,我想将 stdout 和 stderr 重定向到第一个进程。我在用multiprocessing.Pipe
object:
dup2(output_pipe.fileno(), 1)
Where output_pipe
是一个实例multiprocessing.Pipe
。然而,当我尝试在另一端阅读时,它就挂起了。我尝试使用阅读Pipe.recv_bytes
有一个限制,但这提出了OSError
。这是否可能,或者我应该切换到一些较低级别的管道功能?
在 Python 2.7 中进行实验后,我得到了这个工作示例。和os.dup2
管道的文件描述符被复制到标准输出文件描述符,并且每个print
函数最终写入管道。
import os
import multiprocessing
def tester_method(w):
os.dup2(w.fileno(), 1)
for i in range(3):
print 'This is a message!'
if __name__ == '__main__':
r, w = multiprocessing.Pipe()
reader = os.fdopen(r.fileno(), 'r')
process = multiprocessing.Process(None, tester_method, 'TESTER', (w,))
process.start()
for i in range(3):
print 'From pipe: %s' % reader.readline()
reader.close()
process.join()
Output:
From pipe: This is a message!
From pipe: This is a message!
From pipe: This is a message!
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)