如何批量分组执行 Promise 并按序等待每组完成

聖光之護 2025-12-30 00:00:00 次阅读

本文介绍一种简洁可靠的 javascript 模式：将任意长度的 promise 数组按指定批次（如每 2 个一组）顺序执行，确保前一批全部 resolve 后再启动下一批，适用于 api 限流、资源节制等场景。

在实际开发中（例如调用后端接口时需避免并发过多），我们常需控制 Promise 的并发执行数量——不是一次性 Promise.all(promises) 全部触发，也不是逐个 await（效率太低），而是“分批并行、批次串行”：每批内 Promise 并发执行，批与批之间严格等待。

下面是一个通用、可复用的实现方案：

async function runInBatches(promiseFactories, batchSize = 2) {
  for (let i = 0; i < promiseFactories.length; i += batchSize) {
    const batch = promiseFactories.slice(i, i + batchSize);
    // ✅ 批内并发执行，批间 await 阻塞
    await Promise.all(batch.map(fn => fn()));
    console.log(`✅ Batch [${i}–${i + batchSize - 1}] completed`);
  }
}

⚠️ 关键说明：

promiseFactories 是一个函数数组（如 () => axios.post('/api')），而非已创建的 Promise 实例。这是核心设计——避免 Promise 提前执行（即“eager evaluation”），确保每轮只在需要时才触发。
若直接传入 Promise 实例数组（如 [Promise.resolve(1), ...]），它们会在传入时就立即执行，失去分批控制意义。
batchSize 可灵活配置（默认为 2），支持任意正整数。

✅ 使用示例（模拟 API 调用）：

const apiCalls = [
  () => axios.post('/api/users'),
  () => axios.post('/api/posts'),
  () => axios.post('/api/comments'),
  () => axios.post('/api/likes'),
  () => axios.post('/api/shares'),
  () => axios.post('/api/logs')
];

await runInBatches(apiCalls, 2);
// 输出顺序：
// ✅ Batch [0–1] completed   → users + posts 并发完成
// ✅ Batch [2–3] completed   → comments + likes 并发完成  
// ✅ Batch [4–5] completed   → shares + logs 并发完成

? 进阶提示：

如需错误处理，可在 Promise.all() 外加 try/catch，捕获某批中任一 Promise 拒绝；若需“失败跳过继续”，可用 Promise.allSettled() 替代。
结合 AbortController 可为整批添加超时控制，增强鲁棒性。
此模式天然兼容 async/await，无需额外库，零依赖，浏览器与 Node.js 均可直接使用。

掌握这一模式，你就能优雅应对接口限流、大数据分页提交、批量文件上传等典型并发管控需求。