揭秘JavaScript并发控制秘籍，打造高效执行环境

2023-09-13 22:31:53

在开发过程中，我们经常会遇到需要控制任务并发执行数量的需求。例如，一个爬虫程序，可以通过限制其并发任务数量来降低请求频率，从而避免因请求过于频繁而导致被封禁。接下来，本文将介绍如何实现一个并发控制器，帮助你轻松掌控并发的力量。

JavaScript并发控制简介

JavaScript是一种单线程语言，这意味着它一次只能执行一个任务。然而，我们可以通过异步编程来实现并行执行多个任务的假象。异步编程是指将任务排队，让浏览器在主线程空闲时执行它们。

Promise.all实现并发控制

Promise.all是一个内置的JavaScript方法，它可以让你等待多个异步任务完成。我们可以利用它来实现并发控制器。以下是一个示例代码：

// 定义一个并发控制器
const concurrencyController = {
  // 最大并发任务数量
  maxConcurrency: 2,

  // 任务队列
  queue: [],

  // 是否正在执行任务
  running: false,

  // 开始执行任务
  start() {
    if (this.running) {
      return;
    }

    this.running = true;

    // 从队列中取出任务执行
    while (this.queue.length > 0 && this.runningTasks < this.maxConcurrency) {
      const task = this.queue.shift();
      task();
    }

    // 如果队列中还有任务，则继续执行
    if (this.queue.length > 0) {
      setTimeout(() => this.start(), 0);
    } else {
      this.running = false;
    }
  },

  // 添加任务到队列
  addTask(task) {
    this.queue.push(task);
    this.start();
  },

  // 停止执行任务
  stop() {
    this.running = false;
  },

  // 获取正在执行的任务数量
  get runningTasks() {
    return this.queue.length;
  }
};

// 定义任务
const tasks = [
  () => {
    console.log('Task 1');
  },
  () => {
    console.log('Task 2');
  },
  () => {
    console.log('Task 3');
  },
  () => {
    console.log('Task 4');
  },
  () => {
    console.log('Task 5');
  },
  () => {
    console.log('Task 6');
  }
];

// 将任务添加到并发控制器
tasks.forEach(task => concurrencyController.addTask(task));