25

これが私のサブプロセスの場合:

import time, sys
for i in range(200):
    sys.stdout.write( 'reading %i\n'%i )
    time.sleep(.02)

そして、これはサブプロセスの出力を制御および変更するスクリプトです。

import subprocess, time, sys

print 'starting'
    
proc = subprocess.Popen(
    'c:/test_apps/testcr.py',
    shell=True,
    stdin=subprocess.PIPE,
    stdout=subprocess.PIPE  )

print 'process created'

while True:
    #next_line = proc.communicate()[0]
    next_line = proc.stdout.readline()
    if next_line == '' and proc.poll() != None:
        break
    sys.stdout.write(next_line)
    sys.stdout.flush()
    
print 'done'

プロセスが実行されるまで待っているのreadlineはなぜですか? communicateサブプロセスの stdout をリアルタイムで渡す (および変更する) 簡単な方法はありますか?

私はWindows XPを使用しています。

4

2 に答える 2

16

Charles が既に述べたように、問題はバッファリングです。SNMPd 用のいくつかのモジュールを作成しているときに同様の問題に遭遇し、stdout を自動フラッシュ バージョンに置き換えることで解決しました。

ActiveState に関するいくつかの投稿に触発されて、次のコードを使用しました。

class FlushFile(object):
    """Write-only flushing wrapper for file-type objects."""
    def __init__(self, f):
        self.f = f
    def write(self, x):
        self.f.write(x)
        self.f.flush()

# Replace stdout with an automatically flushing version
sys.stdout = FlushFile(sys.__stdout__)
于 2009-02-09T06:12:49.583 に答える
8

プロセス出力はバッファリングされます。より多くの UNIX オペレーティング システム (または Cygwin) では、バッファリング関連の問題を回避するために必要なすべての呪文を列挙する pexpectモジュールが利用可能です。ただし、これらの呪文には、ネイティブ (非 cygwin) の win32 Python ビルドでは使用できない、有効なpty モジュールが必要です。

サブプロセスを制御する例ではsys.stdout.flush()、必要に応じて呼び出すことができますが、任意のサブプロセスの場合、そのオプションは使用できません。

「パイプ (popen()) を使用しないのはなぜですか?」という質問も参照してください。pexpect FAQ で。

于 2009-02-09T05:49:20.717 に答える