Python의 subprocess.PIPE에 대한 비 차단 읽기

질문 : Python의 subprocess.PIPE에 대한 비 차단 읽기

---

하위 프로세스 모듈 을 사용하여 하위 프로세스를 시작하고 해당 출력 스트림 (표준 출력)에 연결합니다. 표준 출력에서 비 차단 읽기를 실행할 수 있기를 원합니다. .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

출처 : https://stackoverflow.com/questions/375427/a-non-blocking-read-on-a-subprocess-pipe-in-python