Rust：main线程不获取线程内容所有权的等待方法及图片渲染优化

核心思路：用Arc<Mutex<JoinHandle<T>>>包装线程句柄 #

JoinHandle::join()会消费自身（转移所有权），导致无法通过共享引用调用。通过Arc<Mutex>包装后，既能安全共享线程句柄，又能在需要等待时锁定获取句柄并调用join，避免所有权转移问题。

具体实现：控制并发+安全等待 #

1. 手动控制并发数（标准库实现） #

用Semaphore（Rust 1.70+稳定版）限制同时运行的线程数，避免一次性创建2400个线程：

use std::sync::{Arc, Mutex, Semaphore};
use std::thread;
use std::time::Duration;

fn main() {
    let total_rows = 2400;
    // 限制同时运行10个线程，可根据CPU核心数调整
    let semaphore = Arc::new(Semaphore::new(10));
    let mut thread_handles = Vec::new();

    for row_idx in 0..total_rows {
        let sem = Arc::clone(&semaphore);
        // 获取许可，达到并发上限时自动阻塞
        let _permit = sem.acquire().unwrap();

        // 创建线程并包装句柄
        let handle = thread::spawn(move || {
            // 模拟行渲染逻辑
            println!("Rendering row {}", row_idx);
            thread::sleep(Duration::from_millis(10));
            // 许可会在_permit离开作用域时自动释放，允许新线程启动
        });

        thread_handles.push(Arc::new(Mutex::new(handle)));
    }

    // 等待所有线程完成
    for handle in thread_handles {
        let mut locked_handle = handle.lock().unwrap();
        locked_handle.join().unwrap();
    }
}

2. 更简洁的线程池方案（第三方库） #

如果不想手动管理并发，用crossbeam的线程池可以自动处理线程复用和等待：

use crossbeam::thread;

fn main() {
    let total_rows = 2400;
    // 创建固定大小的线程池，自动复用线程
    thread::scope(|s| {
        for row_idx in 0..total_rows {
            s.spawn(move |_| {
                println!("Rendering row {}", row_idx);
                // 这里替换为实际的行渲染逻辑
            });
        }
    }).unwrap();
    // 线程池会自动等待所有任务执行完毕
}

关于join报错的原因 #

error[E0507]: cannot move out of *thread which is behind a shared reference是因为join方法会消费JoinHandle（转移其所有权），而你是通过共享引用访问该句柄的。用Arc<Mutex>包装后，我们通过锁定获得可变访问权，调用join时虽然会消费内部的JoinHandle，但Arc<Mutex>本身的所有权仍保留在Vec中，不会影响后续操作。

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