Ausführliche Erklärung und Beispiele für die Verwendung von Asyncio zum Kapseln des Lesens und Schreibens von Dateien in Python

In diesem Artikel wird hauptsächlich erläutert, wie das asyncio.Future -Objekt zum Kapseln des asynchronen Lesens und Schreibens von Dateien verwendet wird. Freunde in Not können sich auf

">

Vorwort

Wie Netzwerk-IO ist auch das Lesen und Schreiben von Dateien ein mühsamer Vorgang. .

Standardmäßig verwendet Python die Lese- und Schreibsperre des Systems. Das bedeutet, dass das

-Ereignis

f = file('xx')
f.read()

blockiert wird, wenn asynchron aufgerufen wird. >Schleife

Dieser Artikel beschreibt kurz, wie man asyncio.Future-Objekte verwendet, um asynchrones Lesen und Schreiben von Dateien zu kapseln

Der Code unterstützt derzeit nur Linux .

Blockierend und nicht blockierend

Zuerst müssen Sie das Lesen und Schreiben der Datei in eine nicht blockierende Form ändern, um sie zu lesen wird sofort zurückgegeben, wenn der Rückgabewert leer ist, bedeutet dies, dass der Dateivorgang nicht abgeschlossen wurde, andernfalls handelt es sich um den gelesenen Dateiinhalt.

Der Wechsel zwischen Blockierung und Nichtblockierung hängt mit der Operation zusammen Daher wird in diesem Artikel nur über die Linux-Version geschrieben. Mit Erfahrung in der Systemprogrammierung werden Sie feststellen, dass die Operationen von Python ähnlich sind das Promise-Objekt in Javascript

Es ist ein Platzhaltersymbol, dessen Wert in der Zukunft berechnet wird Der Wert und die Verwendung von

flag = fcntl.fcntl(self.fd, fcntl.F_GETFL) 
if fcntl.fcntl(self.fd, fcntl.F_SETFL, flag | os.O_NONBLOCK) != 0: 
  raise OSError()

future.set_result(xxx. )

können den Wert der Zukunft festlegen, was bedeutet, dass die Zukunft zurückgegeben werden kann Der Wait--Operator wird Rufen Sie automatisch „future.result()“ auf, um den Wert zu erhalten.

Eine

-Funktion

kann über die Methode „loop.call_soon“ in die Ereignisschleife eingefügt werden An diesem Punkt ist unsere Idee des asynchronen Lesens und Schreibens von Dateien entstanden. Rufen Sie die Funktion zum nicht blockierenden Lesen und Schreiben von Dateien über loop.call_soon auf. Wenn das Lesen und Schreiben der Datei nicht abgeschlossen ist, berechnen Sie die verbleibende Anzahl der gelesenen Bytes und geschrieben, und fügen Sie die Ereignisschleife erneut ein, bis das Lesen und Schreiben abgeschlossen ist. Ich habe festgestellt, dass sie die

while

-Schleife des nicht blockierenden Lesens und Schreibens von Dateien in der herkömmlichen Unix-Programmierung durch die Asyncio-Ereignisschleife ersetzen soll . Das Folgende ist ein schematischer Code für diesen Prozess 🎜>

Das obige ist der detaillierte Inhalt vonAusführliche Erklärung und Beispiele für die Verwendung von Asyncio zum Kapseln des Lesens und Schreibens von Dateien in Python. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!