使用J*aScript实现一个简单的任务队列_js异步编程

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

使用J*aScript实现一个简单的任务队列_js异步编程

2025-10-31

浏览次数：次

返回列表

TaskQueue类通过控制并发数管理异步任务执行顺序，使用Promise实现任务队列，支持按序执行、限制并发及错误处理，在爬虫、上传等场景中有效避免资源竞争。

使用javascript实现一个简单的任务队列_js异步编程

在J*aScript中处理异步操作时，任务队列是一种常见的控制执行顺序的方式。尤其在需要按顺序执行多个异步任务、限制并发数量或实现重试机制时，一个简单的任务队列非常有用。下面是一个基于Promise的轻量级任务队列实现。

任务队列的基本结构

我们定义一个 TaskQueue 类，用于管理异步任务的添加和执行。每个任务都是一个返回 Promise 的函数（也称为“任务函数”），队列会按顺序或指定并发数执行它们。

class TaskQueue {
  constructor(concurrency = 1) {
    this.concurrency = concurrency; // 最大并发数
    this.running = 0;               // 当前正在运行的任务数
    this.queue = [];                // 任务队列
  }

  // 添加任务
  push(task) {
    return new Promise((resolve, reject) => {
      this.queue.push({
        task,
        resolve,
        reject
      });
      this.next();
    });
  }

  // 执行下一个任务
  next() {
    while (this.running < this.concurrency && this.queue.length > 0) {
      const { task, resolve, reject } = this.queue.shift();
      this.running++;

      task()
        .then(resolve, reject)
        .finally(() => {
          this.running--;
          this.next(); // 继续执行下一个
        });
    }
  }
}

使用示例

下面是一个模拟异步任务（如网络请求）的例子，使用 setTimeout 模拟延迟。

// 创建一个最多同时运行2个任务的队列
const queue = new TaskQueue(2);

// 生成一个异步任务
function createTask(id, delay) {
  return () => {
    console.log(`任务 ${id} 开始`);
    return new Promise(resolve => {
      setTimeout(() => {
        console.log(`任务 ${id} 完成`);
        resolve(`结果-${id}`);
      }, delay);
    });
  };
}

// 添加多个任务
queue.push(createTask(1, 1000));
queue.push(createTask(2, 500));
queue.push(createTask(3, 800));
queue.push(createTask(4, 300));

// 可以监听任务完成
queue.push(createTask(5, 600)).then(result => {
  console.log('最终任务完成:', result);
});

输出将显示任务按并发限制逐步执行：1 和 2 先开始，随后是 3、4，最后是 5，但不会超过两个任务同时运行。

动感购物HTML

修正了V1.10的一些BUG感购物HTML系统是集合目前网络所有购物系统为参考而开发，代码采用DIV编号，不管从速度还是安全我们都努力做到最好，此版虽为免费版但是功能齐全，无任何错误，特点有：专业的、全面的电子商务解决方案，使您可以轻松实现网上销售；自助式开放性的数据平台，为您提供充满个性化的设计空间；功能全面、操作简单的远程管理系统，让您在家中也可实现正常销售管理；严谨实用的全新商品数据库，便于