如何并行执行带返回值的Promise？解决queryDatabase并行调用问题

当然可以实现并行执行啦！你的问题出在for循环里的await——每次循环都会等上一个queryDatabase调用完成才会触发下一个，自然就变成串行执行了。要改成并行，核心是用Promise.all()来一次性等待所有异步操作完成，而不是逐个等待。

解决方案代码 #

async function findOrgs(resellers) {
  // 1. 为每个reseller创建一个Promise，执行queryDatabase并提取_id数组
  const promiseList = resellers.map(rese => 
    queryDatabase(rese).then(results => results.map(re => re._id))
  );

  // 2. 并行等待所有Promise完成，拿到所有_id数组的集合
  const allIdGroups = await Promise.all(promiseList);

  // 3. 把多维数组合并成一维数组
  const ao = allIdGroups.flat();

  console.log("done!", ao);
  return ao;
}

为什么这样是并行？ #

当你用map遍历resellers数组时，所有queryDatabase调用会被立刻触发，它们会同时向数据库发起请求，而不是等上一个完成才开始下一个。Promise.all()只是站在原地等待所有异步操作都结束，然后把所有结果汇总回来。

额外处理：容错机制 #

如果担心某个queryDatabase调用失败导致整个流程中断，可以给每个Promise加上catch，出错时返回空数组（或者你需要的默认值），这样其他正常的请求结果依然会被保留：

async function findOrgs(resellers) {
  const promiseList = resellers.map(rese => 
    queryDatabase(rese)
      .then(results => results.map(re => re._id))
      .catch(err => {
        console.error(`处理经销商 ${rese} 时出错:`, err);
        return []; // 出错时返回空数组，不影响整体结果
      })
  );

  const allIdGroups = await Promise.all(promiseList);
  const ao = allIdGroups.flat();

  console.log("done!", ao);
  return ao;
}

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