工程Mar 28, 2026

Deep EVM #24：异步Rust中的上下文传播——截止时间、取消和追踪

Engineering Team

上下文传播的问题

在异步Rust系统中，操作跨越多个异步边界和任务。如何传播截止时间、取消信号和追踪上下文？

截止时间传播

使用tokio的timeout确保操作在截止时间内完成：

use tokio::time::{timeout, Duration};

async fn simulate_with_deadline(
    path: &ArbPath,
    deadline: Duration,
) -> Result<SimResult> {
    timeout(deadline, async {
        // 模拟逻辑
        simulate(path).await
    }).await?
}

取消

tokio的CancellationToken提供协作式取消：

use tokio_util::sync::CancellationToken;

let token = CancellationToken::new();
let child_token = token.child_token();

tokio::spawn(async move {
    tokio::select! {
        result = do_work() => handle_result(result),
        _ = child_token.cancelled() => { /* 清理 */ },
    }
});

// 取消所有子任务
token.cancel();

分布式追踪

使用tracing crate进行结构化日志和追踪：

#[tracing::instrument(skip(db))]
async fn process_opportunity(
    db: &CacheDB,
    path: &ArbPath,
) -> Result<()> {
    tracing::info!("Processing arbitrage path");
    // ...
}

总结

上下文传播是构建可靠异步Rust系统的关键。截止时间、取消令牌和分布式追踪确保系统在高负载下仍然可控和可观测。

标签

Performance Rust