并发控制是限制同时执行的异步任务数量以避免资源过载；不能直接用Promise.all是因为它会无节制并行发起所有请求，易触发后端限流、浏览器连接限制、内存/CPU过载或雪崩。
什么是并发控制，为什么不能直接
一把梭？
当多个
异步任务
（比如 API 请求、文件读取）同时发起时，
会并行启动全部任务——这在低并发场景下没问题，但遇到以下情况就会出问题：
• 后端限流（如 503 Too Many Requests）
•
浏览器
对同一域名的并发连接数限制（通常 6 个）
• 内存或 CPU 过载（尤其处理大量图片/视频 blob）
• 需要按顺序“节流”执行，避免雪崩
用
+ 手动分批最简单可靠
不依赖第三方库，适合中低复杂度场景。核心思路是把任务数组切片，每批最多
个，等一批全完成再发下一批。
}
return runBatch().then(() => results);
}
// 用法：传入一个 Promise 工厂数组，而非已触发的 Promise
const apiCalls = [
() => fetch('/api/user/1'),
() => fetch('/api/user/2'),
() => fetch('/api/user/3'),
// ...
];
limitConcurrency(apiCalls.map(fn => fn())).then(console.log);
⚠️ 注意：
• 一定要传
，不是
，否则调用时就已发起请求
•
确保失败任务不中断整个流程
• 递归调用需小心栈溢出（>1000 批建议改用循环 +
）
立即学习
“
Java免费学习笔记（深入）
”；
用
库做生产级并发管理
如果项目允许引入轻量依赖，
是目前最稳定的选择（仅 1.5KB，无副作用）。它支持真正的“运行中动态控流”，比手动分批更精准。
Comet AI 浏览器
下载 Comet AI 浏览器，体验由 Perplexity AI 驱动的革命性上网方式。内置 AI 助手可实时总结网页、跨标签页对比信息、自动执行任务。告别繁琐操作，让 AI 成为你的浏览副驾，大幅提升研究与工作效率。支持 Windows、macOS、Android 和 iOS。
下载
安装：
关键点：
• 第一个参数是最大并发数（
）
• 第二个参数是待执行函数数组（不是 Promise！）
• 第三个参数是每个函数的包装逻辑，返回值会收集进
• 自动处理错误、暂停、重试（需自行封装）
自定义
类：需要取消、优先级或进度回调时
当业务要求更高控制力（比如用户点击“取消所有请求”，或某任务必须插队），就得自己封装类。核心是维护一个任务队列 + 正在运行的任务 Set。
}
}
使用示例：
⚠️ 注意：取消能力需在
内部用
实现，Executor 本身不介入 Promise 内部逻辑
真正难的不是写个能跑的并发控制器，而是判断什么时候该用分批、什么时候该用池、什么时候必须自己造轮子——尤其当接口响应时间差异大、失败率高、或
前端
要暴露“正在运行 X/10”这类状态时，静态 limit 很容易变成瓶颈。
Promise.allPromise.allPromise.allSettlednfunction limitConcurrency(tasks, limit = 3) {
const results = [];
let index = 0;
async function runBatch() {
const batch = tasks.slice(index, index + limit);
if (batch.length === 0) return;
index += limit;
const batchResults = await Promise.allSettled(batch);
results.push(...batchResults);
await runBatch(); // 串行递归
() => fetch(...)fetch(...)Promise.allSettledawaitasync-poolasync-poolnpm install async-poolimport { pool } from 'async-pool';
const results = await pool(4, apiCalls, async (call) => {
const res = await call();
return res.json();
});
4resultsconcurrentclass ConcurrentExecutor {
constructor(limit = 3) {
this.limit = limit;
this.queue = [];
this.running = new Set();
}
add(promiseFactory, priority = 0) {
return new Promise((resolve, reject) => {
this.queue.push({ promiseFactory, resolve, reject, priority });
this.#run();
});
}
run() {
if (this.running.size >= this.limit || this.queue.length === 0) return;
// 按 priority 排序（高优先级先执行）
this.queue.sort((a, b) => b.priority - a.priority);
const { promiseFactory, resolve, reject } = this.queue.shift();
const task = promiseFactory();
this.running.add(task);
task.then(resolve).catch(reject).finally(() => {
this.running.delete(task);
this.#run(); // 尝试启动下一个
});const executor = new ConcurrentExecutor(2);
executor.add(() => fetch('/api/slow'), 10); // 高优
executor.add(() => fetch('/api/fast'), 1); // 低优promiseFactoryAbortController