Rust如何限制同一时间最多运行10个线程 完成后启动新线程

你当前的代码是串行执行逻辑：循环中每次直接await test(i, file)，会等上一个任务完全执行完成才启动下一个，没有任何并发效果，也无法实现10个任务同时运行的要求。
以下是两种经过生产验证的可行方案，都能实现「同一时间最多运行10个任务，某任务完成后立刻启动新任务填充」的效果： #

方案1：基于Tokio信号量实现（通用、灵活度高） #

使用异步运行时自带的信号量做并发控制，是最通用的实现方式，逻辑清晰可控：

1. 初始化一个容量为10的信号量，作为全局并发许可池
2. 每个任务启动前先申请一个许可，如果当前已有10个任务在运行，申请操作会等待，直到有运行完成的任务释放许可
3. 任务执行结束后自动释放许可，等待队列里的下一个任务会立刻拿到许可启动

示例代码：

use std::sync::Arc;
use tokio::sync::Semaphore;

// 初始化容量为10的信号量，Arc用于跨任务共享所有权
let semaphore = Arc::new(Semaphore::new(10));
let mut task_handles = Vec::new();

for (i, file) in files.iter().enumerate() {
    // 申请许可，无可用许可时自动等待
    let permit = semaphore.clone().acquire_owned().await.unwrap();
    // 派发任务到异步运行时执行
    let handle = tokio::spawn(async move {
        test(i, file).await;
        // 显式drop许可，释放占用的并发名额
        drop(permit);
    });
    task_handles.push(handle);
}

// 等待所有任务执行完毕
for handle in task_handles {
    handle.await.unwrap();
}

方案2：基于Futures流控制实现（代码更简洁） #

如果不想手动管理信号量，可以用futures工具库提供的流缓冲能力，一行配置即可指定最大并发数：

use futures::stream::{self, StreamExt};

// 将任务列表转换为异步流，配置最大并发数10
let _ = stream::iter(files.iter().enumerate())
    .map(|(i, file)| test(i, file))
    // 最大并发数设置为10，任务完成后自动拉取新任务执行，结果返回顺序不固定
    .buffer_unordered(10)
    // 如果需要返回结果和输入顺序一致，把上面的buffer_unordered替换为buffered即可
    // .buffered(10)
    .collect::<Vec<_>>()
    .await;

注意事项 #

• 异步场景下你提到的「线程」表述不准确：test()是异步函数，运行在异步运行时的轻量协程上，并非系统线程，上述两种方案控制的是同时执行的异步任务数，完全匹配你的需求。
• 不要直接一次性spawn所有任务后用join_all等待，这种写法没有并发上限，当文件列表过长时会瞬间创建大量任务，占用过多内存和调度资源。

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