如何在Rust中等待动态列表里的异步函数并发执行完成？

你说得对，Rust标准库的join!宏确实只能处理固定数量的异步任务（以元组形式传入），没法直接适配你这种动态生成的Vec任务列表。不过我们有几个非常实用的方案，完美实现类似JavaScript Promise.all()的功能，让你能并发执行所有异步消费者任务并等待全部完成。

方案1：使用futures crate的join_all（通用异步场景） #

这是最通用的解决方案，适用于任何基于标准Future trait的异步代码。

步骤1：添加依赖 #

首先在你的Cargo.toml中加入futures crate：

[dependencies]
futures = "0.3"

步骤2：修改代码 #

导入join_all并重构你的函数：

use futures::future::join_all;

async fn start_consumers(&self) {
    // 把所有异步任务收集到Vec中
    let consumer_tasks: Vec<_> = self.consumers
        .iter()
        .map(|consumer| consumer.consume())
        .collect();
    
    // 并发执行所有任务，等待全部完成
    join_all(consumer_tasks).await;
}

join_all的行为和你期望的一致：它会同时启动所有异步任务，然后等待每一个任务完成，最终返回一个包含所有任务结果的Vec，结果的顺序和你传入任务的顺序完全对应。

方案2：使用对应异步Runtime的join_all（如Tokio） #

如果你正在使用Tokio作为异步Runtime，Tokio也提供了自己的join_all函数，用法和上面几乎一致，不需要额外引入futures crate：

use tokio::join_all;

async fn start_consumers(&self) {
    let tasks = self.consumers.iter().map(|consumer| consumer.consume());
    join_all(tasks).await;
}

额外：实现类似Promise.all的短路行为（快速失败） #

如果你的异步任务返回Result类型，并且希望像Promise.all一样，只要有一个任务失败就立刻返回错误（不再等待其他任务），可以使用try_join_all（同样来自futures crate或Tokio）：

use futures::future::try_join_all;

// 假设consumer.consume()返回Result<(), YourErrorType>
async fn start_consumers(&self) -> Result<(), YourErrorType> {
    let tasks: Vec<_> = self.consumers
        .iter()
        .map(|consumer| consumer.consume())
        .collect();
    
    // 只要有一个任务返回Err，就立刻终止并返回该错误
    try_join_all(tasks).await?;
    
    Ok(())
}

这样就完全满足了你动态并发执行异步任务并等待全部完成的需求啦！

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