在Rust中使用join_all时如何组合多阶段异步操作？

当然可以把这两个异步阶段合并，只调用一次join_all。核心思路是将发起请求+解析JSON的完整流程包装成单个异步任务（Future），然后一次性并行执行所有这些任务。

优化后的代码 #

let responses = join_all(endpoints.iter().map(|endpoint| async {
    // 把两个异步步骤放在同一个async块里
    self.client.get(endpoint).send().await
        .and_then(|response| response.json::<ResultStruct>().await)
})).await;

细节说明 #

• 每个endpoint对应的异步逻辑被包裹在async块中，这个块会生成一个Future，包含了从发起请求到解析JSON的完整流程。
• join_all会并行执行所有这些Future，无需等待所有请求都返回后再统一解析——一个请求完成后就会立刻开始解析它的JSON，相比原方案能更高效利用时间。
• 关于错误处理：原代码中的unwrap()可能会导致panic，建议用and_then（或?操作符，在async块里需要配合Result返回类型）来处理错误，最终responses会是一个Vec<Result<ResultStruct, Error>>类型，方便后续统一处理成功/失败的结果。

更健壮的错误处理版本：

// 自定义结果类型，也可直接使用reqwest自带的Error类型
type MyResult<T> = Result<T, reqwest::Error>;

let responses: Vec<MyResult<ResultStruct>> = join_all(endpoints.iter().map(|endpoint| async move {
    let response = self.client.get(endpoint).send().await?;
    response.json::<ResultStruct>().await
})).await;

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