
本文介绍一种简洁可靠的 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。
该模式兼顾可控性与性能,是前端批量请求场景的工业级实践方案。










