七秒读懂Promise并发控制，征服200个URL的狂野挑战

2023-11-07 18:06:25

Promise并发控制：驾驭并发请求的七秒秘诀

在当今瞬息万变的网络世界中，并发请求已成为网站和应用程序的必备武器。然而，面对成百上千个同时涌来的请求，仅凭有限的并发请求名额，如何从容应对？别担心，Promise并发控制即将为你揭开绝招，让你轻松驾驭并发请求的挑战！

1. 普通并发池：队列式发送

想象一下，你有一只信鸽和一叠信件。信鸽只能依次传递一封信件，而你却需要同时发送多封信件。普通并发池就像这样的场景，它按照先后顺序依次发送请求，直到并发请求数达到限制。这种方式简单粗暴，但也能确保所有请求最终都会被处理。

2. 动态并发池：智能调配

普通并发池虽然能解决问题，但对于某些场景来说，它并不能充分利用并发请求的优势。动态并发池就像一位经验丰富的信鸽管理员，它会根据情况调整信鸽的数量，以确保所有信件都能在最短时间内送达。它会不断监控并发请求的状态，当某个请求完成时，它会立即派出一只信鸽去执行下一个请求。

3. Promise并发控制实战

理论再好，不如动手一试。我们用一个简单的例子来说明如何使用Promise实现并发请求。

// URL 数组
const urls = ['url1', 'url2', 'url3', 'url4', 'url5'];

// 并发请求数
const concurrency = 5;

// 创建 Promise 队列
const queue = [];

// 创建一个函数来发送请求
const sendRequest = (url) => {
  return new Promise((resolve, reject) => {
    // 模拟发送请求
    setTimeout(() => {
      console.log(`请求 ${url} 已发送`);
      resolve();
    }, 1000);
  });
};

// 函数来管理并发请求
const manageConcurrency = () => {
  // 如果队列不为空且并发请求数小于限制
  while (queue.length && queue.length < concurrency) {
    // 从队列中取出一个请求
    const request = queue.shift();
    // 发送请求
    sendRequest(request);
  }
};

// 将 URL 添加到队列中
urls.forEach((url) => {
  queue.push(url);
});

// 启动并发请求管理
manageConcurrency();