JavaScript 中怎么在宏任务中实现并发任务限流控制-js教程-PHP中文网

javascript宏任务本身串行执行，所谓并发限流实为通过队列+计数器协调异步任务发起节奏，控制如fetch等请求同时发出数量不超过设定阈值。

javascript 中怎么在宏任务中实现并发任务限流控制

在 JavaScript 中，宏任务（如 setTimeout、setInterval、I/O 回调、UI 渲染后回调等）本身是**串行执行**的，无法真正“并发”。所谓“宏任务中实现并发任务限流”，实际是指：**控制一批异步任务（例如多个 fetch、setTimeout 触发的逻辑）以不超过指定并发数的方式，在宏任务队列中有序、可控地执行**。核心不是让宏任务并行，而是用队列 + 令牌桶 / 计数器机制协调任务调度。

用任务队列 + 并发计数器控制执行节奏

这是最直观、易理解的方式：维护一个待执行任务队列和当前运行中的任务数，每次有任务完成就从队列里取下一个执行。

定义最大并发数（如 max = 3）
用数组模拟队列，pending 存待执行函数，running 记当前执行中数量
每个任务包装成返回 Promise 的函数，执行完调用 next() 启动下一个
所有任务通过 add(task) 入队，不立即执行

示例：

class TaskLimiter {
  constructor(max) {
    this.max = max;
    this.pending = [];
    this.running = 0;
  }
  add(task) {
    return new Promise((resolve, reject) => {
      this.pending.push({ task, resolve, reject });
      this.next();
    });
  }
  next() {
    if (this.running >= this.max || this.pending.length === 0) return;
    this.running++;
    const { task, resolve, reject } = this.pending.shift();
    task().then(resolve).catch(reject).finally(() => {
      this.running--;
      this.next(); // 尝试调度下一个
    });
  }
}

// 使用：限制最多 2 个 fetch 同时发出
const limiter = new TaskLimiter(2);
const urls = ['/api/1', '/api/2', '/api/3', '/api/4'];

urls.map(url => () =>
  fetch(url).then(r => r.json())
).forEach(task => limiter.add(task));

用 Promise.allSettled + 分批调度模拟限流

适合已知全部任务列表、且希望分批次“批量提交、批量等待”的场景。把大数组切片，每批最多 max 个，前一批全结束再发下一批。

Java Development Manual

Java开发手册规约集合，基于阿里巴巴Java开发手册（嵩山版）。涵盖7大维度：编程规约、异常日志、单元测试、安全规约、MySQL数据库、工程结构、设计规约。当用户需要：(1) 编写或审查Java代码 (2) 检查命名/代码规范 (3) 处理异常和日志 (4) 编写单元测试 (5) 安全编码 (6) 数据库设...

下载

用 Array.prototype.reduce() 或递归方式串行处理批次
每轮用 Promise.allSettled() 等待本批全部完成（避免因某一个失败中断整体）
注意：该方式吞吐略低（必须等整批完成），但逻辑清晰、无状态管理负担

示例：

async function limitConcurrency(tasks, max) {
  const results = [];
  for (let i = 0; i  t()));
    results.push(...batchResults);
  }
  return results;
}

// 调用
limitConcurrency([
  () => fetch('/a').then(r => r.json()),
  () => fetch('/b').then(r => r.json()),
  () => fetch('/c').then(r => r.json())
], 2);