如何分批执行 Promise 队列并实现串行批次控制

本文介绍一种简洁可靠的 javascript 方案，通过 promise.all 与 async/await 结合循环切片，将任意长度的 promise 数组按固定批次（如每批 2 个）串行执行：前一批全部完成后再启动下一批，避免并发过载。

在实际开发中（如批量调用 API、上传文件或触发高负载任务），我们常需限制并发数以避免服务端限流、内存溢出或请求被拒绝。原生 Promise.all() 会并行执行所有 Promise，而 Promise.allSettled() 或 for...of + await 则退化为完全串行（1 个接 1 个），效率低下。理想的方案是「分批并行 + 批次间串行」——即每批内 Promise 并发执行，批与批之间严格等待。

以下是一个通用、可复用的 runInBatches 函数实现：

/**
 * 按指定批次大小（batchSize）分组执行 Promise 工厂函数数组
 * @param {Array<() => Promise>} promiseFactories - 返回 Promise 的函数数组
 * @param {number} batchSize - 每批并发执行的数量，默认为 2
 * @returns {Promise}
 */
async function runInBatches(promiseFactories, batchSize = 2) {
  for (let i = 0; i < promiseFactories.length; i += batchSize) {
    const batch = promiseFactories.slice(i, i + batchSize);
    // 并发执行当前批次的所有 Promise
    await Promise.all(batch.map(fn => fn()));
    console.log(`✅ 批次 [${i}–${Math.min(i + batchSize - 1, promiseFactories.length - 1)}] 已完成`);
  }
}

// ✅ 使用示例：模拟 6 次 axios.post 调用（带防抖日志）
const apiCalls = Array.from({ length: 6 }, (_, idx) => 
  () => axios.post('/api', { id: idx + 1 })
);

runInBatches(apiCalls, 2)
  .then(() => console.log('? 全部批次执行完毕'))
  .catch(err => console.error('❌ 执行出错:', err));

⚠️ 关键注意事项：

• Promise 工厂函数（而非 Promise 实例）：传入数组必须是 () => Promise 形式（如 () => axios.post(...)），而非已创建的 Promise（如 axios.post(...)）。否则所有 Promise 会在调用 runInBatches 时立即触发，失去批次控制意义。
• 错误处理：Promise.all 遇到任一 Promise reject 会整体失败。如需容错（即某请求失败不影响同批其他请求），请改用 Promise.allSettled：

  await Promise.allSettled(batch.map(fn => fn()));
  // 后续可检查 results[i].status === 'rejected'

• 动态批次大小：batchSize 可根据网络状况、服务端 QPS 限制或用户设备性能动态调整（例如移动端设为 1，桌面端设为 4）。
• 进度反馈：可在 await Promise.all(...) 前添加加载状态更新（如 setLoadingBatch(i / promiseFactories.length)），提升 UX。

该模式兼顾可控性与性能，是前端批量请求场景的工业级实践方案。