本文介绍一种高效控制 promise 执行节奏的方法：将大量异步任务分组为固定大小的批次，每批并行执行，前一批全部完成后再启动下一批，适用于 api 限流、资源节制等场景。
在实际开发中（如调用后端接口），我们常需避免瞬间发起过多请求导致服务端压力过大或触发限流。Promise.all() 虽能并行执行多个 Promise，但若直接传入全部请求，会一次性发出所有请求；而逐个 await 又过于串行、效率低下。理想的方案是：分批并行 + 批次间串行——即每批最多执行 n 个 Promise，并等待整批完成后再处理下一批。
以下是一个简洁、可复用的实现：
async function runInBatches(promiseFactories, batchSize = 2) {
for (let i = 0; i < promiseFactories.length; i += batchSize) {
const batch = promiseFactories.slice(i, i + batchSize);
await Promise.all(batch.map(fn => fn()));
console.log(`✅ Batch ${Math.floor(i / batchSize) + 1} completed: [${i}–${Math.min(i + batchSize - 1, promiseFactories.length - 1)}]`);
}
}
// 示例：模拟 6 个 axios 请求（返回 Promise 的工厂函数）
const apiCalls = [
() => axios.post('/api', { id: 1 }),
() => axios.post('/api', { id: 2 }),
() => axios.post('/api', { id: 3 }),
() => axios.post('/api', { id: 4 }),
() => axios.post('/api', { id: 5 }),
() => axios.post('/api', { id: 6 })
];
// 每批并发 2 个请求
await runInBatches(apiCalls, 2);⚠️ 关键注意事项：
- promiseFactories 必须是函数数组（而非 Promise 实例数组），否则会在调用 runInBatches 时提前执行所有 Promise（造成“立即触发”而非“按需触发”）；
- 若某批中某个 Promise 被 reject，Promise.all() 将立即拒绝整个批次，可结合 Promise.allSettled() 替代以实现“批次内容错继续”；
- 批次大小 batchSize 应根据目标服务的并发承受能力合理设置（常见为 2–10）；
- 如需更高级控制（如动态限流、重试、超时），建议封装为独立工具类或使用成熟库（如 p-limit）。
该模式兼顾性能与可控性，是构建健壮异步流程的重要基础模式之一。
