使用tokio::join处理返回trait类型的映射Future报FnOnce实现通用性不足错误

这个编译错误本质是dyn trait对象的生命周期推断冲突：

• 你代码中所有Box<dyn std::error::Error + Send>的写法没有显式指定生命周期，Rust会在不同上下文自动推断隐式生命周期约束
• 当你用tokio::join!同时等待多个返回dyn Error的Future时，编译器无法证明多个Future返回的trait对象的生命周期是统一匹配的，就会抛出FnOnce实现不够通用的生命周期冲突错误

1. 修复编译的最小改动 #

只需要给所有dyn Error的类型标注显式加上'static生命周期约束（你代码里返回的所有错误本身都是'static生命周期，不存在安全问题），即可通过编译：

use futures::FutureExt;

#[tokio::main]
async fn main() {
    tokio::spawn(async move {
        foo().await;
    })
    .await
    .unwrap();
}

async fn foo() {
    // 启动两个任务
    let worker1 = tokio::spawn(bar(1)).map(|res| res.unwrap());
    let worker2 = tokio::spawn(bar(2)).map(|res| res.unwrap());

    let (error1, error2) = tokio::join!(worker1, worker2);

    let _: Box<dyn std::error::Error + Send + 'static> = error1;
    let _: Box<dyn std::error::Error + Send + 'static> = error2;
}

// 显式指定返回的trait对象为'static生命周期
async fn bar(id: u8) -> Box<dyn std::error::Error + Send + 'static> {
    if id == 1 {
        tokio::time::sleep(core::time::Duration::from_secs(5)).await;
        Box::new(std::io::Error::last_os_error())
    } else {
        panic!("Not yet implemented");
    }
}

注意：这个版本还是无法满足你「任意任务panic立刻转发，无需等待其余任务」的需求，因为tokio::join!必须等待所有传入的Future都执行完成才会返回，worker2抛出的panic会被阻塞到worker1的5秒睡眠结束后才会向上传播。

2. 满足快速失败需求的最优方案 #

你可以使用tokio自带的JoinSet工具管理多个异步任务，它支持在任意任务结束时立刻返回结果，不需要等待其余任务，完美匹配你的需求：

use tokio::task::JoinSet;

#[tokio::main]
async fn main() {
    tokio::spawn(async move {
        foo().await;
    })
    .await
    .unwrap();
}

async fn foo() {
    let mut join_set = JoinSet::new();
    // 把所有任务加入JoinSet
    join_set.spawn(bar(1));
    join_set.spawn(bar(2));

    let mut errors = Vec::with_capacity(2);
    while let Some(res) = join_set.join_next().await {
        // unwrap会直接传播任务的panic，不需要等待剩余任务
        // 剩余未完成的任务会被JoinSet自动abort
        errors.push(res.unwrap());
    }

    let _: Box<dyn std::error::Error + Send + 'static> = errors.remove(0);
    let _: Box<dyn std::error::Error + Send + 'static> = errors.remove(0);
}

async fn bar(id: u8) -> Box<dyn std::error::Error + Send + 'static> {
    if id == 1 {
        tokio::time::sleep(core::time::Duration::from_secs(5)).await;
        Box::new(std::io::Error::last_os_error())
    } else {
        panic!("Not yet implemented");
    }
}

这个版本运行后会立刻捕获到worker2的panic并向上抛出，不需要等待worker1的5秒睡眠。

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