/**
* 实现一个管制 promise 并发个数限度在特定个数的函数 (限度应用 async 和 await 实现):* 例:如须要发送 20 个 fetch 申请,然而同时限度发送个数在 5 个以内,如果 5 个申请发送进来了还剩 15 个申请没有发送,前 5 个申请任何一个申请胜利就要将残余 15 个中一个增加到 4 个正在申请的 pool 外面,最终并发申请为 5。* @Param poolLimit 申请个数限度
* @Param argsArray 申请参数
* @Param iteratorFn 申请函数
* @Return promise 执行后果
*/
async function asyncPool(poolLimit, argsArray, iteratorFn) {const res = [];
const excutings = [];
for (const args of argsArray) {let p = Promise.resolve().then(() => iteratorFn(args));
res.push(p);
if (poolLimit < argsArray.length) {const e = p.then(() => excutings.splice(excutings.indexOf(e), 1));
excutings.push(e);
if (excutings.length >= poolLimit) {await Promise.race(res);
}
}
}
return Promise.all(res);
}