Popen.communicationを理解する

質問

という名前のスクリプトがあります。 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() を使用すると、それは永遠にハングアップします。

どのように解決するのですか？

.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

注意：読み込みと書き込みが同期していないと、デッドロックが発生し、非常に脆弱なコードです。

注意すべきは ブロックバファリング問題 (ここでは stdin, stdout のバッファリングをオフにする "-u" フラグを使用することで解決します。 のバッファリングをオフにします。 ).

bufsize=1 パイプをラインバッファリングにする 親側で .