当前位置：首页 > JavaScript

js 实现一个任务队列

2026-03-02 01:21:59JavaScript

实现任务队列的基本思路

任务队列的核心是管理异步任务的顺序执行，通常需要支持任务添加、执行控制（如并发限制）、错误处理等功能。以下是几种常见实现方式：

基础版：顺序执行异步任务

创建一个队列数组，逐个执行任务，前一个任务完成后再执行下一个：

js 实现一个任务队列

class TaskQueue {
  constructor() {
    this.queue = [];
    this.isRunning = false;
  }

  addTask(task) {
    this.queue.push(task);
    if (!this.isRunning) this.run();
  }

  async run() {
    this.isRunning = true;
    while (this.queue.length > 0) {
      const task = this.queue.shift();
      try {
        await task();
      } catch (error) {
        console.error('Task failed:', error);
      }
    }
    this.isRunning = false;
  }
}

// 使用示例
const queue = new TaskQueue();
queue.addTask(() => new Promise(resolve => setTimeout(() => { console.log('Task 1'); resolve(); }, 1000)));
queue.addTask(() => new Promise(resolve => setTimeout(() => { console.log('Task 2'); resolve(); }, 500)));

进阶版：控制并发数

限制同时执行的任务数量，避免资源过载：

js 实现一个任务队列

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

  addTask(task) {
    this.queue.push(task);
    this.next();
  }

  next() {
    while (this.running < this.concurrency && this.queue.length) {
      const task = this.queue.shift();
      this.running++;
      task().finally(() => {
        this.running--;
        this.next();
      });
    }
  }
}

// 使用示例（并发数为2）
const queue = new ConcurrentQueue(2);
for (let i = 1; i <= 5; i++) {
  queue.addTask(() => new Promise(resolve => 
    setTimeout(() => { console.log(`Task ${i}`); resolve(); }, 1000)
  ));
}

功能增强版：支持优先级

通过优先级字段调整任务执行顺序：

class PriorityQueue {
  constructor() {
    this.queue = [];
  }

  addTask(task, priority = 0) {
    this.queue.push({ task, priority });
    this.queue.sort((a, b) => b.priority - a.priority);
  }

  async run() {
    while (this.queue.length > 0) {
      const { task } = this.queue.shift();
      try {
        await task();
      } catch (error) {
        console.error('Task failed:', error);
      }
    }
  }
}

// 使用示例
const queue = new PriorityQueue();
queue.addTask(() => console.log('Low priority'), 1);
queue.addTask(() => console.log('High priority'), 3);
queue.run();

错误处理与重试

为任务添加自动重试机制：

class RetryQueue {
  constructor(maxRetries = 3) {
    this.queue = [];
    this.maxRetries = maxRetries;
  }

  addTask(task) {
    this.queue.push(task);
  }

  async run() {
    for (const task of this.queue) {
      let retries = 0;
      while (retries <= this.maxRetries) {
        try {
          await task();
          break;
        } catch (error) {
          retries++;
          if (retries > this.maxRetries) console.error('Max retries reached:', error);
        }
      }
    }
  }
}