Rust中如何让克隆的Arc在Tokio任务中拥有足够长的生命周期？

问题原因 #

tokio::spawn要求传入的Future必须满足'static生命周期——Tokio无法保证任务执行时长会短于当前栈帧的生命周期。你的代码中，resolver_ref.lookup_ip(domain_ref)返回的Future会借用resolver_ref，但resolver_ref是在.map()闭包内创建的，闭包执行完毕后就会被销毁，直接违反了'static的约束，导致编译器报错。

解决方案（保持函数式风格） #

核心思路是让Tokio任务拥有所需数据的所有权，而非借用栈上变量，以此满足'static要求，同时不改变原有代码结构。

方案1：将数据所有权移入任务Future

直接把Arc克隆体和域名的String版本移入async move块，让Future持有所有权：

use std::sync::Arc;
use trust_dns_resolver::{
    config::{ResolverConfig, ResolverOpts},
    TokioAsyncResolver,
};

fn main() {
    let rt = tokio::runtime::Builder::new_current_thread()
        .enable_all()
        .build()
        .unwrap();

    rt.block_on(async {
        let cb_domain_iter = vec!["example.com.", "google.com.", "facebook.com."];

        let resolver = Arc::new(
            TokioAsyncResolver::tokio(ResolverConfig::default(), ResolverOpts::default())
                .expect("Could not create resolver"),
        );

        let tasks = cb_domain_iter.iter().map(move |domain| {
            let resolver_clone = resolver.clone();
            let domain_owned = domain.to_string();
            // 将数据移入async块，让Future拥有所有权
            tokio::spawn(async move {
                resolver_clone.lookup_ip(domain_owned).await
            })
        });

        for join in tasks {
            join.await.unwrap();
        }
    })
}

方案2：用Arc包裹原域名列表（避免String转换）

如果不想将域名转为String，可以把原域名列表放入Arc中，通过克隆Arc保证原列表的生命周期覆盖任务执行：

use std::sync::Arc;
use trust_dns_resolver::{
    config::{ResolverConfig, ResolverOpts},
    TokioAsyncResolver,
};

fn main() {
    let rt = tokio::runtime::Builder::new_current_thread()
        .enable_all()
        .build()
        .unwrap();

    rt.block_on(async {
        // 用Arc包裹原域名列表
        let cb_domain_iter = Arc::new(vec!["example.com.", "google.com.", "facebook.com."]);

        let resolver = Arc::new(
            TokioAsyncResolver::tokio(ResolverConfig::default(), ResolverOpts::default())
                .expect("Could not create resolver"),
        );

        let tasks = cb_domain_iter.iter().map(move |domain| {
            let resolver_clone = resolver.clone();
            let domains_arc = cb_domain_iter.clone();
            tokio::spawn(async move {
                resolver_clone.lookup_ip(*domain).await
            })
        });

        for join in tasks {
            join.await.unwrap();
        }
    })
}

关键修改说明 #

• 借助async move块，将Arc克隆体、域名的所有权转移到Future内部，确保Future持有所有依赖的完整所有权，满足'static生命周期要求。
• 两种方案都保留了.map()的函数式风格，未改变原有代码的整体结构。

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