通过维护一个固定大小的并发队列并配合 promise 链可以实现请求并发数限制。核心做法是创建一个任务池，当发起新请求时，若当前活跃请求数未达到上限则立即执行，否则将请求挂起等待，待有请求完成后再从队列中取出下一个继续执行。
如何构建基础的并发控制逻辑
基础逻辑依赖于一个计数器来追踪当前正在进行的请求数量。每当请求开始执行时计数器加一，请求结束（无论成功或失败）时计数器减一并触发后续任务的检查机制。这种模式通常使用递归或循环结构来维持队列的持续消费。
const fetchWithLimit = (urls, limit) => { const results = new Array(urls.length); let index = 0; const queue = []; function runNext() { while (index res.json()); queue.push(task.then((data, i) => { results[i] = data; queue.splice(queue.indexOf(task), 1); if (index { queue.splice(queue.indexOf(task), 1); if (index {})); } } runNext(); return Promise.all(results.map(r => r || Promise.resolve(null))); };
上述代码展示了最核心的实现方式。它利用闭包保存了当前索引和队列状态。每次调用 runNext 都会尝试填充队列直到达到 limit 的限制。每个请求完成后会从队列中移除自身，并检查是否还有剩余任务需要启动。最终返回所有结果的 Promise 数组，确保外部调用者能获取完整数据。
如何处理请求失败与结果收集
在并发控制中，单个请求的失败不应导致整个批次中断，也不应阻塞其他正常请求的执行。因此需要在每个任务内部捕获异常，并将失败位置标记为 null 或特定错误对象，同时保证队列长度正确释放以便后续任务接入。
const safeFetchWithLimit = async (urls, limit) => { const results = new Array(urls.length).fill(null); let activeCount = 0; let currentIndex = 0; const process = async () => { while (currentIndex <p>该版本使用 async/await 语法简化了逻辑。关键区别在于使用 <code>finally</code> 块确保无论请求成功与否，<code>activeCount</code> 都会递减，并再次触发 <code>process</code> 函数以处理队列中的下一个任务。这种方式避免了嵌套回调带来的复杂性，同时保证了并发数的严格限制。如果某个请求抛出异常，对应的结果位置会被填入错误对象，而不会阻止其他请求的正常进行。</p><h2>基于输入URL列表长度的具体表现</h2><p>当输入的 URL 列表长度小于或等于设定的并发限制时，所有请求会几乎同时发出，此时并发控制实际上未起到节流作用，而是表现为并行执行。只有当 URL 数量超过限制时，才会观察到明显的排队现象，即前 N 个请求先执行，后续请求等待前 N 个中的任意一个完成后才启动。</p><p>,</p>
大量免费API接口：立即使用
涵盖生活服务API、金融科技API、企业工商API、等相关的API接口服务。免费API接口可安全、合规地连接上下游，为数据API应用能力赋能！
