如何将impl trait传递给Tokio线程？解决生命周期不足问题

我尝试给每个传入请求把handler传递到线程中，已经用Arc对其进行包装，但出现如下错误：

the parameter type impl ConnectionHandler may not live long enough

相关代码：

impl TCPConnectionHandler {
    pub async fn set_handler(&self, handler: impl ConnectionHandler) {
        let arc_handler = Arc::new(handler);
        loop {
            let handler_clone = arc_handler.clone();
            match self.0.accept().await {
                Ok((mut stream, addr)) => {
                    let join_handle = tokio::task::spawn(async move {    
                        handler_clone.on_incoming_connection(&addr);
                     // ^^^^^^^^^^^^^   
                     // ❌ the parameter type `impl ConnectionHandler` may not live long enough
                    });
                }
                Err(_) => {
                    panic!("Error accepting connection")
                }
            }
        }
    }
}

错误原因 #

Tokio的tokio::task::spawn要求异步任务的生命周期为'static——因为任务可能在任意时间调度执行，无法保证和调用spawn的函数生命周期一致。而当前handler参数没有明确的生命周期约束，编译器默认认为它仅在set_handler函数的生命周期内有效，无法满足spawn任务的要求。同时，跨线程执行的任务还要求数据满足线程安全（Send + Sync）。

代码修改 #

给handler参数添加'static + Send + Sync约束即可解决问题：

impl TCPConnectionHandler {
    // 添加 'static + Send + Sync 约束
    pub async fn set_handler(&self, handler: impl ConnectionHandler + 'static + Send + Sync) {
        let arc_handler = Arc::new(handler);
        loop {
            let handler_clone = arc_handler.clone();
            match self.0.accept().await {
                Ok((mut stream, addr)) => {
                    let join_handle = tokio::task::spawn(async move {    
                        handler_clone.on_incoming_connection(&addr);
                        // 错误消失
                    });
                }
                Err(_) => {
                    panic!("Error accepting connection")
                }
            }
        }
    }
}

约束说明 #

• 'static：确保handler的生命周期足够长，能被Tokio的后台线程任务持有，直到任务执行完成
• Send：允许handler在不同线程间转移所有权
• Sync：允许多个线程通过Arc共享访问handler（Arc本身是线程安全的，但内部数据需要满足Sync才能支持多线程共享）

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