class Scheduler {
  constructor() {
    this.queue = []; // 存储任务的队列
    this.maxConcurrent = 2; // 最大并发数
    this.runningCount = 0; // 当前正在运行的任务数
  }

  add(promiseCreator) {
    return new Promise((resolve, reject) => {
      // 将任务添加到队列中
      this.queue.push({ promiseCreator, resolve, reject });
      // 如果当前正在运行的任务数小于最大并发数，则执行任务
      if (this.runningCount < this.maxConcurrent) {
        this.runTask();
      }
    });
  }

  runTask() {
    if (this.queue.length === 0) return; // 队列为空，直接返回

    const { promiseCreator, resolve, reject } = this.queue.shift();
    this.runningCount++; // 当前正在运行的任务数加一

    promiseCreator()
      .then(resolve)
      .catch(reject)
      .finally(() => {
        this.runningCount--; // 当前正在运行的任务数减一
        this.runTask(); // 继续执行下一个任务
      });
  }
}

const timeout = (time) => new Promise((resolve) => setTimeout(resolve, time));

const scheduler = new Scheduler();

const addTask = (time, order) => {
  scheduler.add(() => timeout(time)).then(() => console.log(order));
};

addTask(1000, "1");
addTask(500, "2");
addTask(300, "3");
addTask(400, "4");