75

我有一个名为的脚本1st.py，它创建了一个 REPL (read-eval-print-loop)：

print "Something to print"
while True:
    r = raw_input()
    if r == 'n':
        print "exiting"
        break
    else:
        print "continuing"

然后我1st.py使用以下代码启动：

p = subprocess.Popen(["python","1st.py"], stdin=PIPE, stdout=PIPE)

然后尝试了这个：

print p.communicate()[0]

它失败了，提供了这个回溯：

Traceback (most recent call last):
  File "1st.py", line 3, in <module>
    r = raw_input()
EOFError: EOF when reading a line

你能解释一下这里发生了什么吗？当我使用p.stdout.read()时，它会永远挂起。

4

3 回答 3

67

.communicate()写入输入（在这种情况下没有输入，因此它只是关闭子进程的标准输入以向子进程指示没有更多输入），读取所有输出，并等待子进程退出。

异常 EOFError 在子进程中由raw_input()（它期望数据但得到 EOF（无数据））引发。

p.stdout.read()永远挂起，因为它试图在孩子等待导致死锁的输入（）的同时读取来自孩子的所有输出。raw_input()

为了避免死锁，您需要异步读/写（例如，通过使用线程或选择）或确切知道何时以及读/写多少，例如：

from subprocess import PIPE, Popen

p = Popen(["python", "-u", "1st.py"], stdin=PIPE, stdout=PIPE, bufsize=1)
print p.stdout.readline(), # read the first line
for i in range(10): # repeat several times to show that it works
    print >>p.stdin, i # write input
    p.stdin.flush() # not necessary in this case
    print p.stdout.readline(), # read output

print p.communicate("n\n")[0], # signal the child to exit,
                               # read the rest of the output, 
                               # wait for the child to exit

注意：如果读/写不同步，这是一个非常脆弱的代码；它陷入僵局。

当心块缓冲问题（这里是通过使用“-u”标志来解决的，该标志关闭 stdin 的缓冲，在 child 中的stdout ）。

bufsize=1使管道在父端进行行缓冲。

于 2013-05-27T09:40:37.363 回答
25

不要使用通信（输入=“”）。它将输入写入进程，关闭其标准输入，然后读取所有输出。

像这样做：

p=subprocess.Popen(["python","1st.py"],stdin=PIPE,stdout=PIPE)

# get output from process "Something to print"
one_line_output = p.stdout.readline()

# write 'a line\n' to the process
p.stdin.write('a line\n')

# get output from process "not time to break"
one_line_output = p.stdout.readline() 

# write "n\n" to that process for if r=='n':
p.stdin.write('n\n') 

# read the last output from the process  "Exiting"
one_line_output = p.stdout.readline()

你会做什么来消除错误：

all_the_process_will_tell_you = p.communicate('all you will ever say to this process\nn\n')[0]

但是由于communication 关闭了stdoutand stdin，stderr所以在调用communicate 之后就不能读或写了。

于 2013-05-27T09:17:38.407 回答
0

您的第二段代码将第一段代码作为具有管道输入和输出的子进程开始。然后它关闭它的输入并尝试读取它的输出。

第一段代码尝试从标准输入中读取，但启动它的进程关闭了它的标准输入，因此它立即到达文件结尾，Python 将其变成异常。

于 2013-05-27T07:31:21.693 回答