如何使用子流程模块与流程正确交互

Question

我在使用子进程模块重定向另一个程序的stdio时遇到问题。仅仅从stdout中读取会导致挂起，并且Popen.communicate（）可以工作，但是在读取/写入后会关闭管道。实现此目的最简单的方法是什么？

我在Windows上玩这个游戏：

import subprocess
proc = subprocess.Popen('python -c "while True: print \'Hi %s!\' % raw_input()"',
                        shell=True, stdin=subprocess.PIPE, stdout=subprocess.PIPE,
                        stderr=subprocess.STDOUT)
while True:
    proc.stdin.write('world\n')
    proc_read = proc.stdout.readline()
    if proc_read:
        print proc_read

Answer 1

并非100％适合您的示例，但有助于理解潜在的问题：进程P启动子项C。子项C向其标准输出中写入内容。C的stdout是一个具有4096个字符缓冲区的管道，其输出比该输出短。现在，C等待一些输入。对于C，一切都很好。

P等待输出永远不会出现，因为OS认为没有理由刷新C的输出缓冲区（其中的数据很少）。由于P永远不会获得C的输出，因此它将永远不会向C写入任何内容，因此C会挂起以等待P的输入。

修复：每写一个管道迫使OS发送数据后刷新使用 现在 。

在您的情况下，proc.stdin.flush()在sys.stdout.flush()打印后在主while循环和子循环中添加应该可以解决您的问题。

您还应该考虑将从另一个进程读取的代码移动到线程中。这里的想法是，您永远无法知道数据何时到达，使用线程可以帮助您在编写处理结果的代码时理解这些问题。

在这个地方，我想向您展示新的Python 2.6文档，但是它也没有解释刷新问题：(哦，好吧…