Promise 如何控制多个异步同时请求的并发量？-JavaScript中文网-JavaScript教程资源分享门户

在前端开发中，经常会遇到需要同时发送多个异步请求的情况。但是过多的异步请求可能会导致性能问题，因此需要控制并发量。Promise 提供了一种简单的方法来控制多个异步请求的并发量，本文将介绍如何使用 Promise 来实现并发量控制，并提供示例代码。

Promise 并发量控制

Promise 是一种用于处理异步操作的对象，它可以让我们更加优雅地处理异步操作，避免回调地狱。在使用 Promise 处理多个异步操作时，我们可以使用 Promise.all 方法来等待所有的操作完成。但是，如果同时发送的异步请求过多，可能会导致性能问题。因此，我们需要控制并发量。Promise 提供了一个方法来控制并发量，即使用 Promise.race 方法来实现。

Promise.race 方法接收一个 Promise 数组作为参数，并返回一个新的 Promise 对象。该方法会等待数组中的任意一个 Promise 对象完成，然后将其结果作为新 Promise 对象的值返回。我们可以将多个异步请求封装成 Promise 对象，并将这些 Promise 对象放入一个数组中，然后使用 Promise.race 方法来控制并发量。

示例代码

下面是一个使用 Promise.race 方法控制并发量的示例代码：

// www.javascriptcn.com code example
function limitConcurrency(urls, maxConcurrency) {
  const results = [];
  let currentIndex = 0;
  const executing = [];

  function execute(url) {
    const promise = fetch(url).then(response => {
      results.push(response);
      executing.splice(executing.indexOf(promise), 1);
    });
    executing.push(promise);
    return promise;
  }

  function run() {
    while (executing.length < maxConcurrency && currentIndex < urls.length) {
      const url = urls[currentIndex];
      execute(url);
      currentIndex++;
    }
    if (executing.length > 0) {
      Promise.race(executing).then(() => {
        run();
      });
    }
  }

  return new Promise(resolve => {
    run();
    Promise.all(executing).then(() => {
      resolve(results);
    });
  });
}

该函数接收两个参数：urls 和 maxConcurrency。urls 是一个包含多个异步请求的 URL 数组，maxConcurrency 是最大并发量。该函数返回一个 Promise 对象，当所有异步请求完成后，该 Promise 对象会将所有结果作为一个数组返回。

该函数使用一个 while 循环来控制并发量。在每次循环中，函数会检查当前正在执行的异步请求数量是否小于最大并发量，如果是，则会执行一个新的异步请求。如果正在执行的异步请求数量超过了最大并发量，则会等待其中任意一个异步请求完成，然后再执行一个新的异步请求。

使用方法

使用上述示例代码中的 limitConcurrency 函数来控制多个异步请求的并发量非常简单。只需要将需要发送的请求的 URL 放入一个数组中，然后调用 limitConcurrency 函数即可。

// www.javascriptcn.com code example
const urls = [
  'https://example.com/api/1',
  'https://example.com/api/2',
  'https://example.com/api/3',
  // ...
];
const maxConcurrency = 3;

limitConcurrency(urls, maxConcurrency).then(results => {
  console.log(results);
});

上述代码将会同时发送三个异步请求，等待其中任意一个请求完成后再发送一个新的请求，直到所有请求都完成。当所有请求都完成后，该函数会将所有结果作为一个数组返回。

来源：JavaScript中文网，转载请注明来源 https://www.javascriptcn.com/post/67d3baeba941bf7134712b1a

Promise 如何控制多个异步同时请求的并发量？

Promise 并发量控制

示例代码

使用方法

接着读