使用Promise.all批量处理Promise时未捕获拒绝致程序崩溃的解决求助

我将多个Promise推入数组，然后用Promise.all()等待它们全部resolve，但只要其中一个被reject，整个程序就会崩溃，无法仅记录错误或获取拒绝值。

初始代码：

async function waiter(string) {
  return new Promise((resolve, reject) => {
    var promisesFor300 = [];

    for (let k = 1; k < 300; k++) {
      promisesFor300.push(
        new Promise((resolve, reject) => {
          // 处理索引相关逻辑
          // resolve或reject
          reject(0);
        }),
      );
    }

    Promise.all(promisesFor300).then(() => {
      resolve("All promises finished without rejection");
    });
  });
}

console.log(await waiter(myStr));

调用reject(0)时出现错误：

[UnhandledPromiseRejection: This error originated either by throwing inside of an async function without a catch block, or by rejecting a promise which was not handled with .catch(). The promise rejected with the reason "0".] {
  code: 'ERR_UNHANDLED_REJECTION'
}

已尝试的方法：

try {
  console.log(await waiter(myStr));
} catch(e) {}

也尝试在for循环内添加try/catch，但没有效果。

期望：捕获到任何拒绝时执行单一操作，而非因拒绝错误导致程序退出。

更新后的代码：

async function waiter(string) {
    var promisesFor300 = [];

    for (let k = 1; k < 300; k++) {
      promisesFor300.push(
        new Promise((resolve, reject) => {
          // 处理索引相关逻辑
          // resolve或reject
          reject(0);
        }),
      );
    }

    return Promise.all(promisesFor300).then(() => {
      return myValueFromCalls;
    });
 
}

console.log(await waiter(myStr))

解决方案 #

核心问题分析 #

Promise.all()的特性是：只要数组中有一个Promise被reject，它就会立即终止并reject，若这个reject未被捕获，就会触发未处理拒绝错误导致程序崩溃。另外初始代码中手动包裹的Promise未处理Promise.all()的reject，导致内部拒绝无法传递到外层；更新后的代码直接返回Promise.all()的结果，但调用时若未正确捕获reject，依然会报错。

方法1：使用Promise.allSettled()等待所有Promise完成 #

该方法会等待所有Promise执行完毕（无论resolve还是reject），返回每个Promise的结果对象，包含status（fulfilled或rejected）和对应的value或reason，适合需要统计所有结果并执行单一操作的场景。

修改示例：

async function waiter(string) {
  const promisesFor300 = [];

  for (let k = 1; k < 300; k++) {
    promisesFor300.push(
      new Promise((resolve, reject) => {
        // 业务逻辑
        reject(0);
      })
    );
  }

  // 等待所有Promise完成
  const results = await Promise.allSettled(promisesFor300);
  
  // 统计失败数量并执行单一操作
  const failedCount = results.filter(item => item.status === 'rejected').length;
  if (failedCount > 0) {
    console.log(`共${failedCount}个Promise被拒绝，执行处理操作`);
    // 这里写你需要的单一处理逻辑
  }

  return results;
}

// 调用时无需额外捕获也不会崩溃
const results = await waiter(myStr);
console.log(results);

方法2：给单个Promise添加catch() #

给每个Promise单独添加catch()，将拒绝转为resolve（返回包含错误信息的对象），这样Promise.all()会正常收集所有结果，之后可统一处理错误。

修改示例：

async function waiter(string) {
  const promisesFor300 = [];

  for (let k = 1; k < 300; k++) {
    promisesFor300.push(
      new Promise((resolve, reject) => {
        // 业务逻辑
        reject(0);
      }).catch(err => ({ 
        error: err, 
        index: k // 可携带索引等额外信息
      }))
    );
  }

  const results = await Promise.all(promisesFor300);
  
  // 检查是否存在错误并执行单一操作
  const hasErrors = results.some(item => item.error);
  if (hasErrors) {
    console.log("存在拒绝的Promise，执行处理操作");
    // 你的处理逻辑
  }

  return results;
}

await waiter(myStr);

方法3：捕获Promise.all()的全局拒绝 #

如果只需要在任意Promise拒绝时执行单一操作，无需保留其他结果，可直接捕获Promise.all()的reject：

修改示例：

async function waiter(string) {
  const promisesFor300 = [];

  for (let k = 1; k < 300; k++) {
    promisesFor300.push(
      new Promise((resolve, reject) => {
        // 业务逻辑
        reject(0);
      })
    );
  }

  try {
    await Promise.all(promisesFor300);
    return myValueFromCalls;
  } catch (err) {
    console.log("捕获到Promise拒绝，执行单一操作");
    // 你的处理逻辑
    // 可选择返回默认值或重新抛出（若需要外层处理）
    return null;
  }
}

await waiter(myStr);

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