JavaScript并发请求：如何依次获取所有请求结果？

本文介绍了如何在JavaScript中实现并发请求并依次获取所有结果。文章首先分析了一个限制并发请求数但无法获取所有结果的代码示例，指出其问题在于多个Promise共享了相同的resolve函数。随后，文章提出了改进方案，通过使用Map对象存储每个请求对应的Promise，解决了这个问题，确保每个请求都能正确获取其响应结果，从而实现了在限制并发数的同时，按顺序处理所有请求的返回。 关键词：JavaScript, 并发请求, Promise, 异步编程, 并发控制

JavaScript并发请求：如何依次获取所有请求结果？

本文探讨如何在JavaScript中，在限制并发请求数量的同时，依次获取每个请求的响应结果。 一个常见场景是限制并发请求数以避免服务器过载，同时需要对每个请求的返回结果进行单独处理。 下面分析一个不完美的例子，并提供改进方案。

问题代码及分析：

以下代码试图限制并发请求数，但结果不尽如人意：

const createpool = (task, { concurrency } = {}) => {
  const pool = [];
  let runningcount = 0;
  return function (i) {
    return new Promise((resolve, reject) => {
      pool.push(() => task(i));
      function run() {
        while (pool.length && runningcount  {
              resolve(val)
            })
            .catch((e) => reject(e))
            .finally(() => {
              runningcount--;
              run();
            });
        }
      }
      run();
    });
  };
};

// 模拟业务调用
const originfetchdata = (id) => {
  return new Promise((resolve) => {
    setTimeout(() => resolve(id), 2000);
  });
};
const fetchdata = createpool(originfetchdata, { concurrency: 5 });

for (let i = 0; i  {
    console.log("response ---", response);  // 问题：只能获取前五个请求的结果
  });
}

该代码的问题在于for循环同步执行，创建了多个Promise，但createpool函数内部的resolve和reject只属于同一个Promise，后来的Promise共享了前几个Promise的resolve函数。

改进方案：

为了解决这个问题，需要为每个请求创建独立的Promise，并将其与请求ID关联起来。可以使用Map对象来存储每个请求的Promise：

const createPool = (task, { concurrency } = {}) => {
  let runningCount = 0;
  const pool = [];
  const promiseMap = new Map();

  return function (i) {
    return new Promise((resolve, reject) => {
      promiseMap.set(i, { resolve, reject });
      pool.push(() => task(i));

      function run() {
        while (pool.length && runningCount  {
              const { resolve } = promiseMap.get(val);
              resolve(val);
            })
            .catch((e) => reject(e))
            .finally(() => {
              runningCount--;
              run();
            });
        }
      }
      run();
    });
  };
};

修改后的createPool函数使用Map对象promiseMap存储每个请求对应的resolve和reject函数，确保每个请求都能正确获取自己的响应结果。 通过这种方式，我们成功地实现了在限制并发请求数量的同时，依次获取所有请求的响应结果。

好了，本文到此结束，带大家了解了《JavaScript并发请求：如何依次获取所有请求结果？》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多文章知识！