promise并发任务队列通过维护running计数器和tasks队列实现，每次最多执行n个任务，完成一个即调度下一个；核心是schedule递归调度、微任务保障及时性、错误隔离不中断队列。

用 Promise 实现并发控制的任务队列，核心是维护一个“运行中任务数”和一个“待执行任务队列”，每次只允许最多 n 个任务同时执行，前一个完成再启动下一个等待任务。

基本思路：用数组 + 计数器 + 递归调度

不依赖外部库，纯 JS 即可实现。关键点有三个：

• 用一个数组缓存待执行的异步任务（每个任务是返回 Promise 的函数）
• 用一个计数器 running 跟踪当前正在执行的任务数量
• 定义一个 schedule() 函数，它检查是否还能启动新任务；能就取一个出来执行，并在 .then() 或 .catch() 后再次调用自己

简单可复用的实现示例

下面是一个轻量、无依赖的并发队列类：

Alibabacloud Sdk Client Initialization For Java

在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。

下载

class TaskQueue {
  constructor(concurrency = 1) {
    this.concurrency = concurrency;
    this.tasks = [];
    this.running = 0;
  }

  push(taskFn) {
    return new Promise((resolve, reject) => {
      this.tasks.push({ taskFn, resolve, reject });
      this.schedule();
    });
  }

  schedule() {
    while (this.running  0) {
      const { taskFn, resolve, reject } = this.tasks.shift();
      this.running++;
      Promise.resolve().then(() => taskFn())
        .then(res => {
          resolve(res);
        })
        .catch(err => {
          reject(err);
        })
        .finally(() => {
          this.running--;
          this.schedule(); // 尝试调度下一个
        });
    }
  }
}

// 使用示例：限制最多 2 个请求同时发出去
const queue = new TaskQueue(2);

const fetchWithDelay = (url, delay = 1000) =>
  () => new Promise(r => setTimeout(() => r(`done: ${url}`), delay));

queue.push(fetchWithDelay('/api/a'));
queue.push(fetchWithDelay('/api/b'));
queue.push(fetchWithDelay('/api/c'));
queue.push(fetchWithDelay('/api/d'));
// a、b 几乎同时开始；c 在 a 或 b 完成后启动；d 类推

注意点和常见优化

实际使用时要注意几个细节：

• 避免同步任务阻塞调度：用 Promise.resolve().then(...) 把任务推到微任务队列，保证调度逻辑不被同步代码卡住
• 错误不中断队列：上面示例中单个任务失败不会影响其他任务，因为 .catch() 后仍会执行 .finally() 触发下一轮调度
• 支持取消（可选）：可在 task 对象里加 signal 或 abort 方法，但需任务函数本身配合（如 fetch() 支持 AbortSignal）
• 想等全部完成？用 Promise.all(queue.results) 不适用——因为 push 返回的是每个任务自己的 Promise，可收集它们：const promises = tasks.map(t => queue.push(t))，再 Promise.all(promises)

更现代写法：用 async/await + 闭包状态

如果偏好 async 风格，也可以封装成函数形式，内部用闭包保存状态：

function createQueue(concurrency = 1) {
  const tasks = [];
  let running = 0;

  const schedule = () => {
    while (running  0) {
      running++;
      const [task, resolve, reject] = tasks.shift();
      task()
        .then(resolve)
        .catch(reject)
        .finally(() => {
          running--;
          schedule();
        });
    }
  };

  return {
    add: (taskFn) => new Promise((resolve, reject) => {
      tasks.push([taskFn, resolve, reject]);
      schedule();
    })
  };
}

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南