如何在NodeJS中实现无休止队列

// 创建一个无休止队列类
class EndlessQueue {
  constructor() {
    this.queue = []; // 存储队列元素的数组
    this.running = false; // 标记队列是否正在运行
  }

  // 向队列中添加任务
  enqueue(task) {
    this.queue.push(task);
    if (!this.running) {
      this.run(); // 如果队列没有在运行，则开始运行队列
    }
  }

  // 运行队列
  run() {
    if (this.queue.length > 0) {
      this.running = true;
      const task = this.queue.shift(); // 取出队列中的第一个任务
      task(() => {
        this.run(); // 递归调用run方法，继续运行队列中的下一个任务
      });
    } else {
      this.running = false;
    }
  }
}

// 创建一个无休止队列实例
const queue = new EndlessQueue();

// 添加任务到队列中
queue.enqueue((callback) => {
  // 执行任务的代码
  console.log('Task 1');
  setTimeout(() => {
    callback(); // 任务完成后调用callback函数，继续运行队列中的下一个任务
  }, 1000);
});

queue.enqueue((callback) => {
  console.log('Task 2');
  setTimeout(() => {
    callback();
  }, 2000);
});

queue.enqueue((callback) => {
  console.log('Task 3');
  setTimeout(() => {
    callback();
  }, 3000);
});