python:multiprocessing.Pipe 和重定向标准输出

Question

我正在使用 multiprocessing 包生成第二个进程，我希望将 stdout 和 stderr 重定向到第一个进程。我正在使用 multiprocessing.Pipe 对象:

dup2(output_pipe.fileno(), 1)

其中output_pipe是multiprocessing.Pipe的实例。然而，当我尝试在另一端阅读时，它就挂起了。我尝试使用带有限制的 Pipe.recv_bytes 进行读取，但这会引发 OSError。这是否可能，或者我应该切换到一些较低级别的管道功能？

Answer 1

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

输出:

From pipe: This is a message!

From pipe: This is a message!

From pipe: This is a message!