如何在Tokio中并行杀死进程向量？

你的代码存在几处问题导致无法正常运行，以下是问题分析和解决办法：

问题点 #

1. 函数定义不完整：缺少fn关键字，且未指定返回类型。
2. 闭包参数处理错误：iter_mut()生成的是&mut tokio::process::Child类型的迭代器，|&mut p|的写法会尝试解引用并移动引用指向的Child实例——但迭代器中的元素是引用，无法被移动。
3. 未处理kill()的返回结果：kill()方法返回std::io::Result<()>，需要明确如何处理这些结果（比如返回第一个错误，或收集所有操作结果）。

修复后的代码 #

方案1：遇到第一个错误立即返回

如果希望只要有一个进程终止失败就立刻停止并返回错误，可以使用try_join_all：

use futures::future;
use std::io;

async fn kill_all(mut processes: Vec<tokio::process::Child>) -> io::Result<()> {
    // 直接对可变引用调用kill，无需移动实例
    let death_futures = processes.iter_mut().map(|p| p.kill());
    
    // 并行执行，遇到错误立即返回
    future::try_join_all(death_futures).await?;
    
    Ok(())
}

方案2：收集所有操作结果

如果需要保留所有进程终止的成功/失败状态，不管是否有错误都等待全部操作完成，可以使用join_all：

use futures::future;
use std::io;

async fn kill_all(mut processes: Vec<tokio::process::Child>) -> Vec<io::Result<()>> {
    let death_futures = processes.iter_mut().map(|p| p.kill());
    // 等待所有future完成，返回包含所有结果的向量
    future::join_all(death_futures).await
}

关键说明 #

• iter_mut()获取的是每个Child的可变引用，kill()方法本身接收&mut self作为参数，因此直接调用p.kill()即可，无需额外解引用操作。
• try_join_all和join_all都会并行执行传入的future，区别在于前者会在第一个错误出现时立即返回，后者会等待所有任务完成后返回全部结果。

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