Rust中如何传播tokio::spawn生成Future的错误？

问题根源 #

直接在tokio::spawn的异步块里用?失败是两个核心原因：

• tokio::spawn生成的任务是由runtime独立调度的，和外层run函数不在同一个调用栈上，错误不可能自动跨spawn边界传播
• 你写的异步块没有显式声明Result返回类型，?无法在非Result返回的异步块里工作；就算给异步块加了Result返回，错误也只会被封装在spawn返回的JoinHandle中，不会自动抛到外层逻辑。

实现方案 #

根据你的业务场景选对应的写法即可：

方案1：等待所有spawn任务执行完成后统一处理错误 #

适合批量spawn任务、所有任务执行完再继续后续逻辑的场景。你需要收集每个spawn返回的JoinHandle，逐个await取出内部结果后再传播错误：

use std::error::Error;
use tokio::task::JoinHandle;

pub async fn run(config: BootingInfo) -> Result<(), Box<dyn Error>> {
    let mut task_handles: Vec<JoinHandle<Result<(), Box<dyn Error + Send + Sync>>>> = vec![];

    loop {
        // 原有业务逻辑，获取connection实例
        // ...

        // 异步块显式声明Result返回值，?可以正常使用
        let handle = tokio::spawn(async move -> Result<(), Box<dyn Error + Send + Sync>> {
            http_service.call(connection).await?;
            Ok(())
        });
        task_handles.push(handle);

        // 原有loop退出逻辑
        // if meet_exit_condition { break; }
    }

    // 遍历所有任务句柄处理结果
    for handle in task_handles {
        // 先处理runtime层错误：任务panic、被取消等
        let task_inner_result = handle.await?;
        // 再处理业务层错误：http_service.call返回的错误
        task_inner_result?;
    }

    Ok(())
}

方案2：常驻服务场景，任意任务报错立刻向上返回 #

如果你的run是常驻服务逻辑，loop无限循环接收请求spawn处理任务，不可能等所有任务执行完，用错误通道把任务内部的错误传到外层即可：

use std::error::Error;
use tokio::sync::mpsc;

pub async fn run(config: BootingInfo) -> Result<(), Box<dyn Error>> {
    // 错误通道，容量根据业务并发量调整
    let (err_sender, mut err_receiver) = mpsc::channel::<Box<dyn Error + Send + Sync>>(16);

    loop {
        tokio::select! {
            // 收到任务报错立刻返回
            Some(err) = err_receiver.recv() => {
                return Err(err);
            }
            // 原有逻辑：接收新连接
            conn = accept_connection() => {
                let conn = conn?;
                let err_sender = err_sender.clone();
                tokio::spawn(async move {
                    // 执行请求处理，报错就发到通道
                    if let Err(call_err) = http_service.call(conn).await {
                        // 发送失败说明外层已经退出，直接忽略即可
                        let _ = err_sender.send(call_err).await;
                    }
                });
            }
        }
    }
}

注意事项 #

• 传给tokio::spawn的Future要求输出类型满足Send + 'static，所以错误类型必须实现Send + Sync，否则会触发编译错误
• 不要漏处理JoinHandle.await返回的JoinError，这层是runtime层面的错误，比如任务panic、调度异常，直接unwrap会导致程序意外崩溃
• 不要试图寻找跨spawn自动传播错误的黑魔法，spawn出去的任务生命周期和父任务没有强绑定，父任务甚至可能先于子任务退出，不可能实现自动的错误透传。

内容的提问来源于stack exchange，提问作者yjlee