class Scheduler {
  constructor(max) {
    this.max = max;        // 最大并发数
    this.running = 0;      // 当前正在执行的任务数
    this.queue = [];       // 等待队列
  }

  add(task) {
    return new Promise((resolve, reject) => {
      // 把任务包装一下，带上 resolve/reject
      const job = () => {
        task().then(resolve, reject).finally(() => {
          this.running--;
          this._runNext();
        });
      };

      if (this.running < this.max) {
        // 没达到并发上限，直接执行
        this.running++;
        job();
      } else {
        // 超过上限，放入等待队列
        this.queue.push(job);
      }
    });
  }

  _runNext() {
    if (this.queue.length > 0) {
      this.running++;
      const job = this.queue.shift();
      job();
    }
  }
}

const scheduler = new Scheduler(2); // 最多同时跑 2 个

function timeout(id, ms) {
  return () => new Promise(resolve => {
    console.log(`任务 ${id} 开始`);
    setTimeout(() => {
      console.log(`任务 ${id} 完成`);
      resolve(id);
    }, ms);
  });
}

scheduler.add(timeout('A', 3000));  // 立即执行
scheduler.add(timeout('B', 1000));  // 立即执行（并发 2）
scheduler.add(timeout('C', 2000));  // 等 A 或 B 完成后执行
scheduler.add(timeout('D', 500));   // 继续排队

// 输出：
// 任务 A 开始
// 任务 B 开始
// 任务 B 完成     （B 先完成，C 开始）
// 任务 C 开始
// 任务 A 完成     （A 完成，D 开始）
// 任务 D 开始
// 任务 C 完成
// 任务 D 完成

// 用户一次性选了 50 张图片，同时上传最多 3 个
const uploadScheduler = new Scheduler(3);

const results = await Promise.all(
  files.map(file => uploadScheduler.add(() => uploadFile(file)))
);

// 爬取 B 站关注列表的 200 个 UP 主动态
const crawler = new Scheduler(3); // 最多 3 个并发

const dynamics = await Promise.all(
  uids.map(uid => crawler.add(() => fetchUserDynamics(uid)))
);

// 首屏同时加载 30 张图片，限制同时最多 4 个
const imgLoader = new Scheduler(4);

images.forEach(img => {
  imgLoader.add(() => loadImage(img.dataset.src));
});

// 100 个测试用例，限制最多 5 个并行
const testRunner = new Scheduler(5);

const results = await Promise.all(
  testCases.map(tc => testRunner.add(() => runTest(tc)))
);