/**
* 实现一个管制 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);
}
发表回复