python，子流程：从子流程中读取输出

Question

我有以下脚本：

#!/usr/bin/python

while True:
    x = raw_input()
    print x[::-1]

我从打来电话ipython：

In [5]: p = Popen('./script.py', stdin=PIPE)

In [6]: p.stdin.write('abc\n')
cba

而且效果很好。

但是，当我这样做时：

In [7]: p = Popen('./script.py', stdin=PIPE, stdout=PIPE)

In [8]: p.stdin.write('abc\n')

In [9]: p.stdout.read()

口译员挂了。我究竟做错了什么？我希望能够多次读写另一个进程，以将一些任务传递给该进程。我需要做些什么？

编辑1

如果使用communicate，则会得到以下信息：

In [7]: p = Popen('./script.py', stdin=PIPE, stdout=PIPE)

In [8]: p.communicate('abc\n')
Traceback (most recent call last):
  File "./script.py", line 4, in <module>
    x = raw_input()
EOFError: EOF when reading a line
Out[8]: ('cba\n', None)

编辑2

我试过冲洗：

#!/usr/bin/python

import sys

while True:
        x = raw_input()
        print x[::-1]
        sys.stdout.flush()

和这里：

In [5]: from subprocess import PIPE, Popen

In [6]: p = Popen('./script.py', stdin=PIPE, stdout=PIPE)

In [7]: p.stdin.write('abc')

In [8]: p.stdin.flush()

In [9]: p.stdout.read()

但它再次挂起。

Answer 1

我相信这里有两个问题在起作用：

1）您的父脚本调用p.stdout.read()，它将读取所有数据，直到文件结束。但是，您的子脚本会无限循环运行，因此文件结束永远不会发生。大概你想要p.stdout.readline()吗？

2）在交互模式下，大多数程序一次只缓冲一行。当从另一个程序运行时，它们缓冲更多。在许多情况下，缓冲可以提高效率，但是当两个程序需要交互通信时会引起问题。

后p.stdin.write('abc\n')加：

p.stdin.flush()

在您的子流程脚本中，在print x[::-1]循环内添加以下内容：

sys.stdout.flush()

（和import sys顶部）