Wie kann verhindert werden, dass Python-Programme beim Lesen der Prozessausgabe hängen bleiben?

Prozessausgabe in Python nicht mehr lesen, ohne zu hängen?

Problem:

Ein Python-Programm muss mit einem externen Programm interagieren Prozess (z. B. „oben“), der kontinuierlich Output produziert. Das einfache direkte Lesen der Ausgabe kann jedoch dazu führen, dass das Programm auf unbestimmte Zeit hängen bleibt.

Lösung:

Um ein Hängenbleiben zu verhindern, ist es wichtig, nicht blockierende oder asynchrone Mechanismen zu verwenden, wenn Ausgabe des Lesevorgangs. Hier sind einige mögliche Ansätze:

Temporäre Spooldatei (empfohlen)

Diese Methode verwendet ein dediziertes Dateiobjekt zum Speichern der Prozessausgabe.

#! /usr/bin/env python<br>Unterprozess importieren<br>Tempfile importieren<br>Zeitpunkt importieren</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 Name == "__main__":

main()

Thread-basiertes Ausgabelesen

Dieser Ansatz verwendet einen separaten Thread, um die Prozessausgabe kontinuierlich zu lesen Der Hauptthread fährt mit anderen Aufgaben fort.

Sammlungen importieren<br>Unterprozess importieren<br>Threading importieren<br>Importzeit</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() (nur Unix)

Diese Methode verwendet Unix-Signale, um den Prozess nach einem angegebenen Timeout zu beenden, unabhängig davon, ob alle Ausgaben gelesen wurden.

Sammlungen importieren<br>Signal importieren<br>Unterprozess importieren</p>
<p>Klasse Alarm (Ausnahme):</p>
<pre class="brush:php;toolbar:false">pass

def alarm_handler(signum, frame):

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

Dieser Ansatz verwendet einen Timer, um den Prozess nach einer bestimmten Zeitüberschreitung zu beenden. Es funktioniert sowohl auf Unix- als auch auf Windows-Systemen.

Sammlungen importieren<br>Unterprozess importieren<br>Threading importieren</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()

Keine Threads, keine Signale

Diese Methode verwendet a einfache zeitbasierte Schleife, um die Prozessausgabe zu prüfen und sie abzubrechen, wenn sie ein bestimmtes Zeitlimit überschreitet.

Sammlungen importieren<br>Unterprozess importieren<br>Systeme importieren<br>Importzeit</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()

Hinweis: Die Anzahl der gespeicherten Zeilen kann nach Bedarf angepasst werden, indem der Parameter „maxlen“ der Deque-Datenstruktur festgelegt wird.

Das obige ist der detaillierte Inhalt vonWie kann verhindert werden, dass Python-Programme beim Lesen der Prozessausgabe hängen bleiben?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!