La programación asíncrona permite que un programa realice múltiples tareas al mismo tiempo sin bloquear la ejecución. En Python, el módulo asyncio proporciona una infraestructura poderosa para escribir código concurrente usando la sintaxis async y await.

1. Corutinas: Funciones que pueden ser pausadas y reanudadas, permitiendo la ejecución de otras tareas mientras esperan.
2. Eventos: Mecanismo que permite a las corutinas esperar hasta que ocurra una condición específica.
3. Loop de Eventos: El núcleo de asyncio, que ejecuta las corutinas y maneja los eventos.

Las corutinas se definen usando la palabra clave async:

Para ejecutar una corutina, se usa asyncio.run():

Vamos a crear un ejemplo donde varias corutinas se ejecutan concurrentemente:

1. Definición de Corutinas:

   async def task(name, delay):
       print(f"Task {name} started")
       await asyncio.sleep(delay)
       print(f"Task {name} finished after {delay} seconds")
   

   • task es una corutina que simula una tarea que toma delay segundos para completarse.
   • await asyncio.sleep(delay) pausa la corutina por delay segundos sin bloquear el loop de eventos.

2. Ejecutar Múltiples Corutinas Concurrentemente:

   async def main():
       await asyncio.gather(
           task("A", 2),
           task("B", 1),
           task("C", 3)
       )
   

   • asyncio.gather ejecuta múltiples corutinas concurrentemente y espera a que todas terminen.

3. Iniciar el Loop de Eventos:

   asyncio.run(main())
   

   • asyncio.run(main()) inicia el loop de eventos y ejecuta la corutina main.

Escribe un programa que descargue el contenido de varias páginas web concurrentemente usando asyncio y aiohttp.

1. Importar Módulos Necesarios:

   import asyncio
   import aiohttp
   

2. Definir la Corutina fetch:

   async def fetch(url):
       async with aiohttp.ClientSession() as session:
           async with session.get(url) as response:
               return await response.text()
   

   • aiohttp.ClientSession se usa para manejar la sesión HTTP.
   • session.get(url) realiza una solicitud GET a la URL.
   • await response.text() obtiene el contenido de la respuesta.

3. Definir la Corutina main:

   async def main():
       urls = [
           'https://www.python.org',
           'https://www.asyncio.org',
           'https://www.github.com'
       ]
       tasks = [fetch(url) for url in urls]
       results = await asyncio.gather(*tasks)
       for result in results:
           print(result[:100])  # Imprimir los primeros 100 caracteres de cada página
   

   • urls es una lista de URLs para descargar.
   • tasks es una lista de corutinas fetch para cada URL.
   • await asyncio.gather(*tasks) ejecuta todas las corutinas concurrentemente y espera a que todas terminen.
   • for result in results imprime los primeros 100 caracteres de cada página descargada.

4. Iniciar el Loop de Eventos:

   asyncio.run(main())
   

En esta sección, hemos aprendido sobre la programación asíncrona en Python usando el módulo asyncio. Hemos cubierto los conceptos básicos de corutinas, eventos y el loop de eventos, y hemos visto cómo ejecutar corutinas concurrentemente. También hemos trabajado con un ejemplo práctico de descarga de páginas web concurrentemente.

En el próximo módulo, exploraremos técnicas avanzadas de concurrencia, incluyendo el uso de hilos y procesos.