Explication détaillée et exemples d'utilisation d'asyncio pour encapsuler la lecture et l'écriture de fichiers en Python

Cet article explique principalement comment utiliser l'objet asyncio.Future pour encapsuler la lecture et l'écriture asynchrones de fichiers. Les amis dans le besoin peuvent se référer à

">

Avant-propos

Comme les IO réseau, la lecture et l'écriture de fichiers sont également une opération gênante. .

Par défaut, Python utilise le blocage en lecture et en écriture du système. Cela signifie que si

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

est appelé en asyncio, l'événement sera bloqué. >Boucle.

Cet article décrit brièvement comment utiliser les objets asyncio.Future pour encapsuler la lecture et l'écriture asynchrones de fichiers

Le code ne prend actuellement en charge que Linux. .

Blocage et non bloquant

Tout d'abord, vous devez modifier la lecture et l'écriture du fichier en une forme non bloquante, chaque appel à lire. reviendra immédiatement, si la valeur de retour est vide. , cela signifie que l'opération sur le fichier n'est pas terminée, sinon c'est le contenu du fichier lu

Le basculement entre bloquant et non bloquant est lié au fonctionnement. système, donc cet article ne parle que de la version Linux. Avec une expérience en programmation système, vous constaterez que les opérations de Python sont similaires à

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

Objet futur

L'objet futur est similaire à. l'objet Promise en Javascript C'est un symbole d'espace réservé, sa valeur sera calculée dans le futur. On peut utiliser

result = wait future

pour revenir après. le futur obtient la valeur et utiliser

future.set_result(xxx. )

peut définir la valeur du futur, ce qui signifie que le futur peut être renvoyé L'opérateur wait <.> appellera automatiquement future.result() pour obtenir la valeur loop.call_soon

Une

fonction

peut être insérée dans la boucle d'événement via la méthode loop.call_soon

<.> À ce stade, notre idée de lecture et d'écriture de fichiers asynchrones est apparue. Appelez la fonction de lecture et d'écriture de fichiers non bloquantes via loop.call_soon. Si la lecture et l'écriture de fichiers ne sont pas terminées, calculez le nombre restant de. octets lus et écrits, et insérez à nouveau la boucle d'événement jusqu'à ce que la lecture et l'écriture soient terminées. Il s'avère que dans la programmation Unix traditionnelle, la boucle non bloquante de lecture et d'écriture de fichier while est remplacée par l'événement asyncio. boucle. Ce qui suit est un code schématique pour ce processus 🎜>.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!