#并发请求控制：前端网络调度的艺术

/**
 * 并发控制函数
 * @param {Array} urls - 需要请求的 URL 数组或任务参数
 * @param {Number} max - 最大并发数
 * @param {Function} fetcher - 具体的请求层函数，接受 url 返回 Promise
 * @returns {Promise} 所有请求完成后的结果数组
 */
function concurrentRequest(urls, max, fetcher) {
  return new Promise((resolve) => {
    // 处理空边界
    if (urls.length === 0) {
      resolve([]);
      return;
    }

    const results = [];
    let index = 0; // 当前执行到了哪个 url 的索引
    let activeCount = 0; // 当前正在路上的请求数量
    let finishedCount = 0; // 已经彻底归来的请求数量

    // 这是一条流水线的工人，他干完一个活，就会自动去领下一个活
    async function requestWorker() {
      // 退出条件：所有任务都被领光了
      if (index >= urls.length) return;

      // 领任务，同时主动把索引推给下一个工人
      const currentUrlIndex = index++;
      const currentUrl = urls[currentUrlIndex];
      activeCount++;

      try {
        const res = await fetcher(currentUrl);
        results[currentUrlIndex] = { status: 'fulfilled', value: res };
      } catch (err) {
        // 请求失败同样算是归槽，不要卡爆流水线
        results[currentUrlIndex] = { status: 'rejected', reason: err };
      } finally {
        activeCount--;
        finishedCount++;

        // 如果全部打完收工了，向外部 resolve
        if (finishedCount === urls.length) {
          resolve(results);
        } else {
          // 如果还没干完，这个闲下来的流水线工人去领下一个任务！
          requestWorker();
        }
      }
    }

    // 引擎启动：由于有 max 限制，我们就雇佣 max 个流水线工人同时开工
    const poolSize = Math.min(urls.length, max);
    for (let i = 0; i < poolSize; i++) {
      requestWorker();
    }
  });
}