使用Tokio Runtime时异步代码因boxed error无法编译的解决方案

问题根源 #

Tokio的runtime.spawn要求提交的future必须实现Send trait，因为多线程runtime会在不同线程间调度任务。你的代码中，external_function返回的Result<i32, Box<dyn Error>>里，Box<dyn Error>没有限定Send约束，导致整个future不满足Send，触发编译错误。

解决方案 #

由于无法修改external_function，我们可以在await之后将错误转换为带有Send约束的类型，确保future满足Send要求。具体做法是把Box<dyn Error>转换成Box<dyn Error + Send>，让整个future符合spawn的调度要求。

修改后的代码 #

use std::error::Error;

async fn external_function() -> Result<i32, Box<dyn Error>>{
  println!("This is an external function!");
  Ok(1)
}

async fn my_function(something: i32) {
  println!("This is my function {something}");
}

fn main() {
  println!("Hello, world!");
  let runtime = tokio::runtime::Runtime::new().unwrap();
  runtime.spawn(async move {
    // 将错误转换为带Send约束的类型，满足spawn的要求
    let v = external_function().await.map_err(|e| e as Box<dyn Error + Send>);
    if let Ok(x) = v {
        my_function(x).await;
    }
  });
  // 等待异步任务执行完成，避免main提前退出终止runtime
  runtime.shutdown_background();
}

补充说明 #

• 转换Box<dyn Error>到Box<dyn Error + Send>是安全的，因为绝大多数标准库和第三方crate的错误类型都实现了Send trait。
• 添加runtime.shutdown_background()是为了让main函数等待spawn的异步任务执行完毕，否则main退出时会直接终止runtime，导致任务被强制中断。

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