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

Python에서 하위 프로세스 파이프에 대한 비차단 읽기를 수행하는 방법

Python에서 하위 프로세스 모듈로 작업할 때 다음이 필요할 수 있습니다. 하위 프로세스의 출력 스트림에서 비차단 읽기를 수행합니다. 이렇게 하면 사용 가능한 데이터가 없을 수 있는 프로세스에서 읽을 때 프로그램이 차단되지 않습니다.

기존 차단 읽기

일반적으로 다음 코드는 다음과 같습니다. 하위 프로세스의 표준 출력에서 ​​읽는 데 사용됩니다.

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

그러나 이 접근 방식은 다음이 될 때까지 프로그램 실행을 차단합니다. 데이터는 표준 출력에서 ​​사용할 수 있습니다.

비차단 읽기

비차단 읽기를 구현하기 위한 일반적인 방법 중 하나는 Python 대기열의 Queue 클래스를 사용하는 것입니다. 기준 치수. 예는 다음과 같습니다.

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

이 코드에서 enqueue_output 함수는 별도의 스레드에서 실행되며 출력에서는 하위 프로세스 stdout放入队列中。主线程可以随时调사용 q.get_nowait()来检查队列中是否有数据.如果没有数据，它将引发 비어있는 异常，而如果成功，它将返回提取的行。

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