ThreadPool传递Arc<&PbwtInfo>触发逃逸错误，求无克隆解决方案

你遇到的核心问题是线程池闭包要求'static生命周期，但你传递的&PbwtInfo引用仅在函数内部有效，导致编译器判定引用逃逸。原代码中Arc<&PbwtInfo>的写法本质是把一个短期引用包装进Arc，并没有改变引用的生命周期，因此无法满足线程池的要求。

而你不想克隆大体积的PbwtInfo对象，最优解法是使用作用域线程（scoped threads）——它允许线程使用函数内的引用，同时保证引用在线程运行期间始终有效，无需'static约束。

方案1：使用标准库std::thread::scope（Rust 1.63+） #

标准库从1.63版本开始内置了作用域线程，无需额外依赖：

use std::sync::mpsc;
use std::thread;

// 直接接收&PbwtInfo引用，无需Arc包装
pub fn impute(pbwt_data: &pbwt::PbwtInfo, test_sequences: Vec<Vec<u8>>) -> Vec<Vec<u8>> {
    let N = test_sequences.len();
    let mut fin_imputed: Vec<Vec<u8>> = vec![Vec::new(); N];
    let (tx, rx) = mpsc::channel();

    // 作用域线程保证所有子线程在闭包结束前完成，因此pbwt_data的引用始终有效
    thread::scope(|scope| {
        for (i, tst_seq) in test_sequences.into_iter().enumerate() {
            let tx = tx.clone();
            scope.spawn(move || {
                // 直接使用原引用，无需克隆PbwtInfo
                let val = impute_single(pbwt_data, &tst_seq);
                let ret = RowWPos { position: i as u32, row: val };
                tx.send(ret).unwrap();
            });
        }
    });

    drop(tx);
    for recd in rx.iter() {
        fin_imputed[recd.position as usize] = recd.row;
    }

    fin_imputed
}

方案2：使用第三方scoped_threadpool crate #

如果你的Rust版本低于1.63，可以使用成熟的第三方作用域线程池库：

1. 添加依赖到Cargo.toml：

[dependencies]
scoped_threadpool = "1.0"

2. 修改代码：

use scoped_threadpool::Pool;
use std::sync::mpsc;

pub fn impute(pbwt_data: &pbwt::PbwtInfo, test_sequences: Vec<Vec<u8>>) -> Vec<Vec<u8>> {
    let N = test_sequences.len();
    let mut fin_imputed: Vec<Vec<u8>> = vec![Vec::new(); N];
    let (tx, rx) = mpsc::channel();
    let mut pool = Pool::new(8);

    pool.scoped(|scope| {
        for (i, tst_seq) in test_sequences.into_iter().enumerate() {
            let tx = tx.clone();
            scope.execute(move || {
                let val = impute_single(pbwt_data, &tst_seq);
                let ret = RowWPos { position: i as u32, row: val };
                tx.send(ret).unwrap();
            });
        }
    });

    drop(tx);
    for recd in rx.iter() {
        fin_imputed[recd.position as usize] = recd.row;
    }

    fin_imputed
}

作用域线程的核心逻辑是：所有子线程必须在作用域闭包结束前完成执行，因此函数内的引用（如pbwt_data）的生命周期完全覆盖线程的运行周期，编译器可以安全地允许线程使用这些引用，无需强制'static约束。

这种方案既避免了大对象克隆的性能开销，又彻底解决了引用逃逸的生命周期错误。

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