关于javascript:限制请求数量函数

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

评论

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

这个站点使用 Akismet 来减少垃圾评论。了解你的评论数据如何被处理