Usare Asyncio in Python

Appendice B. Materiale supplementare

Questa appendice contiene del codice aggiuntivo relativo ai casi di studio presentati nel libro. Potresti trovare questo materiale utile per completare la tua comprensione degli esempi.

Esempio di posate con Asyncio

"Caso di studio: Robot e posate" ha analizzato un bug di race condition causato da più thread che modificano i record delle posate nell'istanza globale dell'oggetto "cucina". Per completezza, ecco come potremmo creare una versione asincrona della soluzione.

C'è un punto specifico che voglio sottolineare riguardo all'osservabilità della concorrenza nell'approccio asyncio, mostrato nell'Esempio B-1.

Esempio B-1. Gestione delle posate con 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 = attrib(default=0)
    forks = attrib