标签导航：

javascript并发编程：如何正确获取所有异步请求的结果？

JavaScript并发控制与异步结果完整获取

本文探讨如何在JavaScript并发程序中，确保所有异步请求的结果都能被正确获取。 许多开发者在使用并发控制时，会遇到for循环只能获取部分异步结果的问题，这是因为异步操作的特性与循环执行顺序不匹配。

原始代码通常使用一个createPool函数实现并发限制，但其内部的Promise resolve和reject函数在循环中被重复利用。 当循环快速执行完毕后，大量异步任务等待执行，但它们共享相同的resolve和reject，导致只有少数异步任务的结果能被捕获。

改进后的方法的核心在于使用Map对象promiseMap来分别存储每个任务对应的Promise的resolve和reject函数。 promiseMap以任务ID作为键，存储对应的resolve/reject函数，确保每个异步任务都能找到其专属的resolve函数来返回结果。

以下是改进后的createPool函数：

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 < concurrency) {
          const task = pool.shift();
          runningCount++;
          task()
            .then((val) => {
              const { resolve } = promiseMap.get(val);
              resolve(val);
            })
            .catch((e) => reject(e))
            .finally(() => {
              runningCount--;
              run();
            });
        }
      }
      run();
    });
  };
};

通过promiseMap，每个异步任务都能正确地将结果传递给对应的resolve函数，从而在循环中完整获取所有任务的结果，解决了原始代码中只能获取部分结果的问题。