프로세스 출력을 읽을 때 Python 프로그램이 중단되는 것을 방지하는 방법은 무엇입니까?

정지 없이 Python에서 프로세스 출력 읽기를 중지하시겠습니까?

문제:

Python 프로그램은 외부 프로그램과 상호 작용해야 합니다. 지속적으로 출력을 생성하는 프로세스(예: "top")입니다. 그러나 단순히 출력을 직접 읽는 것만으로도 프로그램이 무기한 정지될 수 있습니다.

해결책:

정지 현상을 방지하려면 다음과 같은 경우 비차단 또는 비동기 메커니즘을 사용하는 것이 필수적입니다. 프로세스 출력을 읽는 중입니다. 다음은 몇 가지 가능한 접근 방식입니다.

스풀 임시 파일(권장)

이 방법은 전용 파일 객체를 활용하여 프로세스 출력을 저장합니다.

#! /usr/bin/env python<br>하위 프로세스 가져오기<br>임시 파일 가져오기<br>가져오기 시간</p>
<p>def main():</p>
<pre class="brush:php;toolbar:false"># Open a temporary file (automatically deleted on closure)
f = tempfile.TemporaryFile()

# Start the process and redirect stdout to the file
p = subprocess.Popen(["top"], stdout=f)

# Wait for a specified duration
time.sleep(2)

# Kill the process
p.terminate()
p.wait()

# Rewind and read the captured output from the file
f.seek(0)
output = f.read()

# Print the output
print(output)
f.close()

if 이름 == "__main__":

main()

스레드 기반 출력 읽기

이 접근 방식은 별도의 스레드를 사용하여 프로세스 출력을 계속해서 읽습니다. 메인 스레드는 다른 작업을 진행합니다.

컬렉션 가져오기<br>하위 프로세스 가져오기<br>스레딩 가져오기<br>가져오기 시간</p>
<p>def read_output(process,append):</p>
<pre class="brush:php;toolbar:false">for line in iter(process.stdout.readline, ""):
    append(line)

def main():

# Start the process and redirect stdout
process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True)

# Create a thread for output reading
q = collections.deque(maxlen=200)
t = threading.Thread(target=read_output, args=(process, q.append))
t.daemon = True
t.start()

# Wait for the specified duration
time.sleep(2)

# Print the saved output
print(''.join(q))

if name == "__main__":

main()

signal.alarm()(Unix 전용)

이 메서드는 모든 출력을 읽었는지 여부에 관계없이 Unix 신호를 사용하여 지정된 시간 초과 후 프로세스를 종료합니다.

컬렉션 가져오기<br>신호 가져오기<br>하위 프로세스 가져오기</p>
<p>class Alarm(Exception):</p>
<pre class="brush:php;toolbar:false">pass

def Alarm_handler(signum, 프레임):

raise Alarm

def main():

# Start the process and redirect stdout
process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True)

# Set signal handler
signal.signal(signal.SIGALRM, alarm_handler)
signal.alarm(2)

try:
    # Read and save a specified number of lines
    q = collections.deque(maxlen=200)
    for line in iter(process.stdout.readline, ""):
        q.append(line)
    signal.alarm(0)  # Cancel alarm
except Alarm:
    process.terminate()
finally:
    # Print the saved output
    print(''.join(q))

if name == "__main__":

main()

threading.Timer

이 접근 방식은 타이머를 사용하여 지정된 시간 초과 후 프로세스를 종료합니다. Unix와 Windows 시스템 모두에서 작동합니다.

import collections<br>import subprocess<br>import threading</p>
<p>def main():</p>
<pre class="brush:php;toolbar:false"># Start the process and redirect stdout
process = subprocess.Popen(["top"], stdout=subprocess.PIPE, close_fds=True)

# Create a timer for process termination
timer = threading.Timer(2, process.terminate)
timer.start()

# Read and save a specified number of lines
q = collections.deque(maxlen=200)
for line in iter(process.stdout.readline, ""):
    q.append(line)
timer.cancel()

# Print the saved output
print(''.join(q))

if name == "__main__":

main()

스레드 없음, 신호 없음

이 방법은 프로세스 출력을 확인하고 지정된 시간 초과를 초과하는 경우 이를 종료하는 간단한 시간 기반 루프입니다.

import collections<br>import subprocess<br>import sys<br>import time</p> <p>def main():</p>
<pre class="brush:php;toolbar:false">args = sys.argv[1:]
if not args:
    args = ['top']

# Start the process and redirect stdout
process = subprocess.Popen(args, stdout=subprocess.PIPE, close_fds=True)

# Save a specified number of lines
q = collections.deque(maxlen=200)

# Set a timeout duration
timeout = 2

now = start = time.time()
while (now - start) < timeout:
    line = process.stdout.readline()
    if not line:
        break
    q.append(line)
    now = time.time()
else:  # On timeout
    process.terminate()

# Print the saved output
print(''.join(q))

if name == "__main__":

main()

참고: deque 데이터 구조의 'maxlen' 매개변수를 설정하여 필요에 따라 저장된 라인 수를 조정할 수 있습니다.

위 내용은 프로세스 출력을 읽을 때 Python 프로그램이 중단되는 것을 방지하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!