Tasks

Rust tiene un sistema de tareas, que es una forma de hilo ligero.

Una tarea tiene un solo futuro de nivel superior que el ejecutor sondea para hacer que progrese. El futuro puede tener uno o varios futuros anidados que su método poll sondea, lo que se corresponde con una pila de llamadas. La concurrencia dentro de una tarea es posible mediante el sondeo de varios futuros secundarios , como una carrera de un temporizador y una operación de E/S.

use tokio::io::{self, AsyncReadExt, AsyncWriteExt};
use tokio::net::TcpListener;

#[tokio::main]
async fn main() -> io::Result<()> {
    let listener = TcpListener::bind("127.0.0.1:0").await?;
    println!("escuchando en el puerto {}", listener.local_addr()?.port());

    loop {
        let (mut socket, addr) = listener.accept().await?;

        println!("conexión de {addr:?}");

        tokio::spawn(async move {
            socket.write_all(b"¿Quién eres?\n").await.expect("error de socket");

            let mut buf = vec![0; 1024];
            let name_size = socket.read(&mut buf).await.expect("error de socket");
            let name = std::str::from_utf8(&buf[..name_size]).unwrap().trim();
            let reply = format!("¡Gracias por llamar, {name}!\n");
            socket.write_all(reply.as_bytes()).await.expect("error de socket");
        });
    }
}