如何在并行执行Promise时按完成顺序处理结果并汇总最终结果？

当然可以实现！你已经注意到Promise.all会严格按照输入数组的顺序返回结果，不管每个Promise的完成时间，但如果想要在Promise完成时就实时处理结果，同时最终汇总出按resolve顺序排列的结果数组，我们可以封装一个可复用的工具函数，用现代async/await语法轻松实现。

核心思路 #

所有Promise依然并行执行（因为它们在创建时就已经开始运行了），我们给每个Promise包装一层逻辑：当它resolve时，立刻触发自定义的处理逻辑，并将结果按完成顺序存入数组。最后等待所有Promise执行完毕，返回这个按resolve顺序排列的结果数组。

可复用工具函数实现 #

async function processPromisesInResolveOrder(promises, onResolve) {
  const orderedResults = [];
  
  // 给每个Promise包装处理逻辑
  const wrappedPromises = promises.map(promise => 
    promise.then(result => {
      // 实时处理当前完成的结果（如果传入了处理回调）
      if (typeof onResolve === 'function') {
        onResolve(result);
      }
      // 将结果按完成顺序加入数组
      orderedResults.push(result);
      return result;
    })
  );
  
  // 等待所有Promise执行完成
  await Promise.all(wrappedPromises);
  
  // 返回按resolve顺序排列的汇总结果
  return orderedResults;
}

使用示例 #

用你给出的Promise数组来测试：

const promises = [
  new Promise(res => setTimeout(() => res("A"), 3000)),
  new Promise(res => setTimeout(() => res("B"), 1000)),
  new Promise(res => setTimeout(() => res("C"), 2000)),
];

// 调用工具函数，传入实时处理回调和Promise数组
const finalResults = await processPromisesInResolveOrder(promises, (result) => {
  console.log(`刚完成的Promise结果: ${result}`); // 会依次输出 "B"、"C"、"A"
});

console.log("最终汇总结果（按resolve顺序）:", finalResults); // 输出 ["B", "C", "A"]

扩展：错误处理 #

如果需要处理Promise reject的情况，可以给工具函数添加错误处理逻辑，比如：

async function processPromisesInResolveOrder(promises, onResolve, onReject) {
  const orderedResults = [];
  
  const wrappedPromises = promises.map(promise => 
    promise
      .then(result => {
        if (typeof onResolve === 'function') onResolve(result);
        orderedResults.push({ success: true, value: result });
        return result;
      })
      .catch(error => {
        if (typeof onReject === 'function') onReject(error);
        orderedResults.push({ success: false, error: error });
        // 可选：如果不想因为单个Promise失败而终止整个流程，可以注释掉下面的throw
        throw error;
      })
  );
  
  try {
    await Promise.all(wrappedPromises);
  } catch (e) {
    // 这里可以处理整体的错误，比如记录日志
    console.error("有Promise执行失败:", e);
  }
  
  return orderedResults;
}

为什么这个方案可行？ #

• 所有Promise从一开始就并行执行，没有因为包装逻辑而变成串行。
• 每个Promise的.then回调会在它resolve时立即执行，因此结果会按完成顺序被加入数组。
• Promise.all只是用来等待所有Promise执行完毕，不影响结果的收集顺序。

内容的提问来源于stack exchange，提问作者Anayo Samson Oleru