
本文介绍一种简洁可靠的 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 均可直接使用。
掌握这一模式,你就能优雅应对接口限流、大数据分页提交、批量文件上传等典型并发管控需求。










