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

Question

我在使用子进程模块重定向另一个程序的stdio时遇到了问题。仅仅从标准输出读取会导致挂起，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将某些内容写入其stdout。C的stdout是一个管道，它有一个4096个字符的缓冲区，并且输出比这个更短。现在，C等待一些输入。对于C来说，一切都很好。

P等待永远不会出现的输出，因为操作系统认为没有理由刷新C的输出缓冲区(其中的数据非常少)。因为P永远不会得到C的输出，所以它不会向C写任何东西，所以C会挂起，等待来自P的输入。

修复:在每次写入管道后使用刷新，强制操作系统现在发送数据。

在本例中，在主while循环中添加proc.stdin.flush()，并在打印后的子循环中添加sys.stdout.flush()，就可以解决您的问题。

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

在这里，我想向您展示新的Python2.6文档，但它也没有解释刷新问题:(哦，好吧…