Utiliser Asyncio en Python

Annexe B. Matériel supplémentaire

Cette annexe contient du code supplémentaire lié aux études de cas présentées dans le livre. Tu trouveras peut-être ce matériel utile pour compléter ta compréhension des exemples.

Exemple de couverts utilisant Asyncio

"Étude de cas : Robots et couverts" a analysé un bogue de condition de course causé par plusieurs threads modifiant les enregistrements de couverts dans l'instance globale de l'objet "cuisine". Pour être complet, voici comment nous pourrions créer une version asynchrone de la solution.

Il y a un point spécifique que je veux souligner à propos de l'observabilité de la concurrence dans l'approche asyncio, illustrée dans l'exemple B-1.

Exemple B-1. Gestion des couverts à l'aide d'asyncio

import asyncio

class CoroBot():  
  def __init__(self):
    self.cutlery = Cutlery(knives=0, forks=0)
    self.tasks = asyncio.Queue()  

  async def manage_table(self):
    while True:
      task = await self.tasks.get()  
      if task == 'prepare table':
        kitchen.give(to=self.cutlery, knives=4, forks=4)
      elif task == 'clear table':
        self.cutlery.give(to=kitchen, knives=4, forks=4)
      elif task == 'shutdown':
        return

from attr import attrs, attrib

@attrs
class Cutlery:
    knives ...