Wie erreicht man nicht blockierende Subprozess-Pipe-Lesevorgänge in Python?

So führen Sie nicht blockierende Lesevorgänge für Subprozess-Pipes in Python durch

Bei der Arbeit mit dem Subprozessmodul in Python kann dies erforderlich sein Führen Sie nicht blockierende Lesevorgänge für den Ausgabestrom eines Unterprozesses durch. Dadurch wird sichergestellt, dass das Programm beim Lesen aus einem Prozess, für den möglicherweise keine Daten verfügbar sind, nicht blockiert.

Traditionelle blockierende Lesevorgänge

Typischerweise wäre der folgende Code Wird verwendet, um aus der Standardausgabe eines Unterprozesses zu lesen:

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

Dieser Ansatz blockiert jedoch die Ausführung des Programms, bis Daten im Standard verfügbar sind Ausgabe.

Nicht blockierende Lesevorgänge

Um nicht blockierende Lesevorgänge zu implementieren, ist eine gängige Methode die Verwendung der Queue-Klasse aus dem Python-Warteschlangenmodul. Hier ist ein Beispiel:

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

In diesem Code wird die Funktion „enqueue_output“ in einem separaten Thread ausgeführt und die Ausgabe erfolgt im Unterprozess „stdout“.如果没有数据，它将引发 Leer异常，而如果成功，它将返回提取的行.

Das obige ist der detaillierte Inhalt vonWie erreicht man nicht blockierende Subprozess-Pipe-Lesevorgänge in Python?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!