하위 프로세스 파이프에서 비차단 읽기를 수행하는 방법은 무엇입니까?

비차단 방식으로 하위 프로세스 파이프에서 읽기

하위 프로세스로 작업할 때 상위 프로세스가 중단되지 않도록 비차단 읽기를 수행하는 것이 중요할 수 있습니다. 자식 프로세스의 출력을 기다리는 동안. 문제는 사용 가능한 데이터가 없으면 readline()이 차단되는 subprocess.Popen을 사용할 때 발생합니다.

전통적인 차단 접근 방식

일반적으로 개발자는 다음 코드를 사용하여 읽습니다. 하위 프로세스의 표준 출력에서:

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

그러나 이 접근 방식은 다음과 같은 경우 실행을 차단합니다. 데이터를 사용할 수 있습니다.

비차단 솔루션

신뢰할 수 있는 크로스 플랫폼 솔루션에는 아래 코드에 설명된 대로 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

이 접근 방식은 별도의 스레드를 사용하여 출력 행을 대기열에 넣습니다. 그러면 메인 스레드는 get_nowait()를 사용하여 큐에 차단 없이 데이터가 포함되어 있는지 확인할 수 있습니다. 이 휴대용 솔루션을 사용하면 다양한 운영 체제에서 하위 프로세스 출력에 대한 비차단 읽기가 가능합니다.

위 내용은 하위 프로세스 파이프에서 비차단 읽기를 수행하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!