JavaScript并发控制下如何依次获取所有异步任务的结果？

JavaScript并发控制与异步结果的顺序获取

本文探讨在JavaScript并发控制函数中，如何确保依次获取所有异步任务结果的问题。 问题根源在于原代码中，并发控制函数虽然限制了并发任务数量，但由于Promise的resolve和reject函数被错误地共享，导致后续异步任务的结果无法正确传递。

原代码中createPool函数试图限制并发，但for循环内的fetchData(i).then(…)部分使用了同一个Promise的resolve和reject，使得后来的异步任务无法将结果正确传递到相应的then函数。 由于for循环快速执行，创建了大量Promise实例，但因并发限制，只有前几个Promise能及时执行，其余实例的resolve和reject函数被覆盖，导致仅能获取部分结果。

解决方案是为每个异步任务创建一个唯一的Promise实例，并关联其对应的resolve和reject函数。改进后的代码如下：

立即学习“Java免费学习笔记（深入）”；

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

登录后复制