Padrões Async em Rust

Padrões de produção para programação async em Rust com o runtime Tokio, incluindo tarefas, canais, streams e tratamento de erros.

Quando Usar Esta Habilidade

• Construindo aplicações async em Rust
• Implementando serviços de rede concorrentes
• Usando Tokio para I/O async
• Tratando erros async corretamente
• Depurando problemas de código async
• Otimizando performance async

Conceitos Principais

1. Modelo de Execução Async

Future (lazy) → poll() → Ready(value) | Pending
                ↑           ↓
              Waker ← Runtime schedules

2. Abstrações Chave

Início Rápido

# Cargo.toml
[dependencies]
tokio = { version = "1", features = ["full"] }
futures = "0.3"
async-trait = "0.1"
anyhow = "1.0"
tracing = "0.1"
tracing-subscriber = "0.3"

use tokio::time::{sleep, Duration};
use anyhow::Result;

#[tokio::main]
async fn main() -> Result<()> {
    // Initialize tracing
    tracing_subscriber::fmt::init();

    // Async operations
    let result = fetch_data("https://api.example.com").await?;
    println!("Got: {}", result);

    Ok(())
}

async fn fetch_data(url: &str) -> Result<String> {
    // Simulated async operation
    sleep(Duration::from_millis(100)).await;
    Ok(format!("Data from {}", url))
}

Padrões Detalhados e Exemplos Práticos

A documentação detalhada de padrões está em references/details.md. Leia este arquivo quando o nível de navegação acima for insuficiente.

Melhores Práticas

Fazer

• Use tokio::select! - Para competir entre futures
• Prefira canais - Em vez de estado compartilhado, quando possível
• Use JoinSet - Para gerenciar múltiplas tarefas
• Instrumente com tracing - Para depurar código async
• Trate cancelamento - Verifique CancellationToken

Não Fazer

• Não bloqueie - Nunca use std::thread::sleep em código async
• Não mantenha locks (travas) entre awaits - Causa deadlocks
• Não "spawn" (crie) sem limites - Use semáforos para limites
• Não ignore erros - Propague com ? ou registre
• Não esqueça os limites Send - Para futures "spawnados"