JavaScript数组并发请求需用“队列+并发池”模型控制请求数量，如p-limit库或手写Promise池，配合Promise.allSettled保证结果顺序与错误处理。
JavaScript 数组遍历实现并发限制请求任务，核心是控制同时发起的请求数量（比如最多 3 个），避免压垮后端或触发浏览器限制。这不是简单用 for 或 map 发请求，而是需要“队列 + 并发池”模型。
用 PromisePool 控制并发数
最直接的方式是使用轻量工具库（如 p-limit）或手写一个 Promise 池。它维护一个运行中的任务队列，新任务等待空闲 slot 才执行。
- 安装：
npm install p-limit - 用法示例：对用户 ID 数组批量请求用户详情，限制 2 个并发
import pLimit from 'p-limit';
const limit = pLimit(2); // 最多 2 个并发
const userIds = [1, 2, 3, 4, 5];
const promises = userIds.map(id =>
limit(() => fetch(`/api/user/${id}`).then(r => r.json()))
);
const results = await Promise.all(promises);
每个 limit(fn) 返回一个 Promise，只有当前运行中任务数 fn；否则排队等待。
手写并发控制函数（无依赖）
适合不想引入额外包的场景。关键点：维护 running 计数、用 async/await + 递归调度。
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
立即学习“Java免费学习笔记（深入）”；
- 定义
runWithLimit(tasks, max)，接收异步任务数组和最大并发数 - 内部用
next()递归取任务执行，执行前检查是否已达上限 - 每个任务完成后调用
next()继续调度
async function runWithLimit(tasks, max) {
const results = [];
let running = 0;
let index = 0;
return new Promise((resolve) => {
function next() {
if (index >= tasks.length && running === 0) {
resolve(results);
return;
}
while (running < max && index < tasks.length) {
const task = tasks[index++];
running++;
task()
.then(res => results.push(res))
.catch(err => results.push(err))
.finally(() => {
running--;
next();
});
}
}
next();
});
}
// 使用
const tasks = userIds.map(id => () => fetch(`/api/user/${id}`).then(r => r.json()));
const results = await runWithLimit(tasks, 3);
结合 async/await + for 循环（串行但可控）
如果不需要“尽可能并发”，只是想防止瞬间发太多请求，可用带暂停的 for 循环——每次发一个，等返回再发下一个。虽非并发，但简单可靠，适合调试或低频场景。
- 用
for...of配合await，天然串行 - 加
delay可进一步控频（如每秒 1 个）
function delay(ms) {
return new Promise(resolve => setTimeout(resolve, ms));
}
for (const id of userIds) {
const res = await fetch(`/api/user/${id}`).then(r => r.json());
results.push(res);
await delay(200); // 可选：请求间隔
}
错误处理与结果顺序保持
并发请求下，失败不能中断整个流程，且通常需按原数组顺序返回结果（哪怕中间某个失败了）。
- 用
Promise.allSettled替代Promise.all，确保所有请求完成 - 手写池方案中，在
.catch中仍 push 结果（如null或错误对象） - 不依赖执行顺序，只靠原始索引映射结果位置（例如传入
{ id, idx }）
const tasks = userIds.map((id, idx) =>
limit(() => fetch(`/api/user/${id}`)
.then(r => r.json())
.then(data => ({ success: true, data, idx }))
.catch(err => ({ success: false, error: err.message, idx }))
);
const all = await Promise.all(tasks);
const results = Array(userIds.length);
all.forEach(({ idx, ...rest }) => results[idx] = rest);
