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();
});
};
};
改进后的createPool函数使用Map对象promiseMap存储每个任务的Promise实例及其对应的resolve和reject函数。 这样，每个异步任务都能正确地将结果传递到对应的then函数。promiseMap使用任务ID (即i)作为键，方便后续根据ID获取对应的resolve函数。 then方法中，通过promiseMap.get(val)获取对应的resolve函数，确保每个任务的结果都被正确处理。
此修改确保每个fetchData(i)调用都返回一个独立的Promise，从而保证每个任务的结果都能被正确记录和处理，从而解决异步任务结果丢失的问题，并保证结果的顺序性。
