NodeJS中如何等待指定数量Promise完成后继续执行？

原生的Promise.all()、Promise.any()等方法确实无法直接满足“等待n个Promise成功，或所有Promise完成后再继续”的需求，我们可以自己封装一个工具函数来实现这个逻辑：

function promiseWaitN(promises, requiredResolves) {
  return new Promise((resolve) => {
    const totalTasks = promises.length;
    // 边界情况处理：要求的成功数<=0直接返回空结果；要求数>=总任务数等价于allSettled
    if (requiredResolves <= 0) return resolve({ resolved: [], rejected: [] });
    if (requiredResolves >= totalTasks) return Promise.allSettled(promises).then(resolve);

    let resolvedCount = 0;
    let completedCount = 0;
    const resolvedResults = [];
    const rejectedReasons = [];

    promises.forEach((task, index) => {
      // 确保非Promise类型的任务也能被正确处理
      Promise.resolve(task)
        .then((result) => {
          resolvedResults[index] = result;
          resolvedCount++;
          completedCount++;
          // 满足终止条件：达到要求的成功数，或所有任务都已完成
          if (resolvedCount === requiredResolves || completedCount === totalTasks) {
            resolve({
              resolved: resolvedResults.filter(item => item !== undefined),
              rejected: rejectedReasons.filter(item => item !== undefined)
            });
          }
        })
        .catch((reason) => {
          rejectedReasons[index] = reason;
          completedCount++;
          // 所有任务完成时触发resolve
          if (completedCount === totalTasks) {
            resolve({
              resolved: resolvedResults.filter(item => item !== undefined),
              rejected: rejectedReasons.filter(item => item !== undefined)
            });
          }
        });
    });
  });
}

使用示例 #

比如你有10个异步任务，想要等其中5个（50%）成功就继续执行，或者所有任务完成后再继续：

// 模拟随机成功/失败的异步任务
function createAsyncTask(taskId) {
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      Math.random() > 0.3 ? resolve(`任务${taskId}成功`) : reject(`任务${taskId}失败`);
    }, Math.random() * 1000);
  });
}

// 生成10个测试任务
const tasks = Array.from({ length: 10 }, (_, i) => createAsyncTask(i + 1));

// 等待5个成功任务，或所有任务完成
promiseWaitN(tasks, 5)
  .then(({ resolved, rejected }) => {
    console.log(`已完成${resolved.length}个成功任务：`, resolved);
    console.log(`已完成${rejected.length}个失败任务：`, rejected);
    // 这里编写后续业务逻辑
  });

关键细节说明 #

1. 兼容非Promise输入：用Promise.resolve()包裹每个任务，确保普通值也能被正确处理
2. 双终止条件：只要达到指定的成功数，或者所有任务都完成（无论成败），都会立即返回结果
3. 结果收集：返回对象包含已成功的结果数组和已失败的原因数组，方便后续处理
4. 不中断未完成任务：函数触发resolve后，未完成的任务仍会继续执行，只是提前进入后续逻辑（如果需要中断任务，需额外结合AbortController实现）

内容的提问来源于stack exchange，提问作者Sanjay S B