Rust线程池任务中传递线程池引用的实现问题

你的核心问题是线程池的引用无法满足任务闭包的'static生命周期要求，原代码里的&ThreadPool是栈上变量的引用，而线程池任务闭包必须能存活到任意线程执行的时间点，不能依赖栈上的临时引用。

解决思路是用Arc（原子引用计数指针）包装线程池，实现多线程安全的共享所有权：

1. 导入Arc模块：use std::sync::Arc;
2. 把线程池实例包装成Arc<ThreadPool>，让每个任务持有一个克隆的Arc指针
3. 提交任务时克隆Arc，通过move闭包将所有权转移给任务

修正后的完整代码：

use num_cpus;
use threadpool::ThreadPool;
use std::sync::Arc;

// 修改参数为Arc<ThreadPool>，支持多线程共享
fn func2(pool: Arc<ThreadPool>) {
    // 克隆Arc传递给下一个任务
    let pool_clone = Arc::clone(&pool);
    pool.execute(move || func2(pool_clone));
}

fn func1() {
    // 用Arc包装线程池
    let pool = Arc::new(ThreadPool::new(num_cpus::get()));
    
    // 克隆Arc并move到闭包中
    let pool_clone = Arc::clone(&pool);
    pool.execute(move || func2(pool_clone));

    pool.join();
}

关键说明 #

• Arc是线程安全的引用计数容器，多个线程可同时持有它的克隆实例，只有当所有克隆都被销毁时，内部的线程池才会被释放
• 每次提交任务时克隆Arc，是为了保证每个任务都持有独立的引用计数，避免线程池在任务执行前被提前销毁
• move闭包会把克隆后的Arc所有权转移到任务中，满足闭包的'static生命周期要求

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