[解決済み] Pythonでサブプロセス.PIPEをノンブロッキングで読み込む

質問

を使用しています。 サブプロセスモジュール を使用してサブプロセスを開始し、その出力ストリーム (標準出力) に接続します。私は、その標準出力でノンブロッキングリードを実行できるようにしたいです。.readlineをノンブロッキングにする方法や、ストリームにデータがあるかどうかチェックする方法はありますか？ .readline ? ポータブルであること、少なくともWindowsとLinuxで動作することを希望します。

今のところ、私がやっている方法は以下の通りです（ブロック化されているのは .readline を使用します(データがない場合)。

p = subprocess.Popen('myprogram.exe', stdout = subprocess.PIPE)
output_str = p.stdout.readline()

解決方法は？

fcntl , select , asyncproc はこの場合、役に立ちません。

オペレーティングシステムに関係なく、ブロッキングせずにストリームを読み込む信頼性の高い方法として Queue.get_nowait() :

import sys
from subprocess import PIPE, Popen
from threading  import Thread

try:
    from queue import Queue, Empty
except ImportError:
    from Queue import Queue, Empty  # python 2.x

ON_POSIX = 'posix' in sys.builtin_module_names

def enqueue_output(out, queue):
    for line in iter(out.readline, b''):
        queue.put(line)
    out.close()

p = Popen(['myprogram.exe'], stdout=PIPE, bufsize=1, close_fds=ON_POSIX)
q = Queue()
t = Thread(target=enqueue_output, args=(p.stdout, q))
t.daemon = True # thread dies with the program
t.start()

# ... do other things here

# read line without blocking
try:  line = q.get_nowait() # or q.get(timeout=.1)
except Empty:
    print('no output yet')
else: # got line
    # ... do something with line