在Tokio异步任务中使用async-trait的dyn对象遇编译错误求助

问题场景 #

开发基于Tokio的异步Rust应用时，使用async-trait crate定义异步Trait并作为dyn对象使用，但在tokio::spawn生成的任务中使用该对象时遭遇编译错误。

最小复现代码 #

use std::time::Duration;

use async_trait::async_trait;

#[tokio::main]
async fn main() {
    // 参考async-trait crate中dyn trait的示例编写
    let value = MyStruct::new();
    let object = &value as &dyn MyTrait;

    tokio::spawn(async move {
        object.foo().await;
    });
}

#[async_trait]
trait MyTrait {
    async fn foo(&self);
}

struct MyStruct {}

impl MyStruct {
    fn new() -> MyStruct {
        MyStruct {}
    }
}

#[async_trait]
impl MyTrait for MyStruct {
    async fn foo(&self) {
        tokio::time::sleep(Duration::from_secs(1)).await;
    }
}

编译错误信息 #

error: future cannot be sent between threads safely
   --> src/main.rs:11:18
    |
11  |       tokio::spawn(async move {
    |  __________________^
12  | |         object.foo().await;
13  | |     });
    | |_____^ future created by async block is not `Send`
    |
    = help: the trait `Sync` is not implemented for `dyn MyTrait`
note: captured value is not `Send` because `&` references cannot be sent unless their referent is `Sync`
   --> src/main.rs:12:9
    |
12  |         object.foo().await;
    |         ^^^^^^ has type `&dyn MyTrait` which is not `Send`, because `dyn MyTrait` is not `Sync`
note: required by a bound in `tokio::spawn`
   --> /home/wilyle/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-1.25.0/src/task/spawn.rs:163:21
    |
163 |         T: Future + Send + 'static,
    |                     ^^^^ required by this bound in `spawn`

error: could not compile `async-test` due to previous error

疑问与解答 #

1. 原代码为何无法运行？ #

这不是库兼容性问题，而是Rust线程安全规则和Tokio任务调度的要求导致的：

• tokio::spawn生成的任务可能被调度到任意线程执行，因此要求任务（即async块生成的Future）必须实现Send trait，确保可以安全跨线程传递。
• 原代码中捕获的&dyn MyTrait引用，要满足Send，其指向的类型必须实现Sync（因为共享引用&T的Send实现依赖T: Sync）。但默认情况下，dyn MyTrait并没有自动带上Sync约束，编译器无法确认该trait对象是否满足线程安全要求，因此报错。
• 另外，原代码中value是main函数栈上的变量，object是对它的引用，而tokio::spawn要求任务满足'static生命周期（不能捕获栈上的临时引用），这也是隐藏的问题——即便解决了Send/Sync问题，后续还会遇到生命周期不满足'static的错误。

2. 添加Send + Sync约束的解决方案是否正确？ #

这个方案是完全正确的，原因如下：

• Box<dyn MyTrait + Send + Sync>将对象放在堆上，满足了'static生命周期要求（堆上对象的生命周期不受栈帧限制）。
• Send + Sync约束明确告诉编译器，这个trait对象可以安全地跨线程传递（Send），且可以被多个线程同时共享（Sync），符合tokio::spawn对任务的线程安全要求。
• 你的MyStruct类型本身是一个空结构体，默认自动实现了Send和Sync，所以加上这些约束是合法的。如果后续结构体包含非线程安全的字段，编译器会及时提醒你调整。

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