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 중국어 웹사이트의 기타 관련 기사를 참조하세요!