如何限制并发请求数？

class RequestQueue {
  constructor(maxConcurrent) {
    this.maxConcurrent = maxConcurrent; // 最大并发数
    this.queue = []; // 请求队列
    this.activeCount = 0; // 正在处理的请求数
  }

  // 添加请求到队列
  add(requestFn) {
    return new Promise((resolve, reject) => {
      const task = () => {
        this.activeCount++;
        requestFn()
          .then(resolve)
          .catch(reject)
          .finally(() => {
            this.activeCount--;
            this.next(); // 一个请求完成后，尝试执行下一个
          });
      };

      // 如果未达并发上限，立即执行；否则入队等待
      if (this.activeCount < this.maxConcurrent) {
        task();
      } else {
        this.queue.push(task);
      }
    });
  }

  // 执行队列中的下一个任务
  next() {
    if (this.queue.length > 0 && this.activeCount < this.maxConcurrent) {
      const nextTask = this.queue.shift();
      nextTask();
    }
  }
}

// 使用示例
const queue = new RequestQueue(3); // 限制最多同时3个请求

// 模拟异步请求函数
const mockRequest = (id, delay) => () => 
  new Promise(resolve => setTimeout(() => resolve(`请求 ${id} 完成`), delay));

// 添加10个请求到队列
for (let i = 0; i < 10; i++) {
  queue.add(mockRequest(i, 1000)).then(result => console.log(result));
}