const timeout = i => new Promise(resolve => setTimeout(() => resolve(i), i));
await asyncPool(2, [1000, 5000, 3000, 2000], timeout);

function asyncPool(poolLimit, array, iteratorFn){ ... }

const timeout = i => new Promise(resolve => setTimeout(() => resolve(i), i));
await asyncPool(2, [1000, 5000, 3000, 2000], timeout);
// Call iterator (i = 1000)
// Call iterator (i = 5000)
// Pool limit of 2 reached, wait for the quicker one to complete...
// 1000 finishes
// Call iterator (i = 3000)
// Pool limit of 2 reached, wait for the quicker one to complete...
// 3000 finishes
// Call iterator (i = 2000)
// Itaration is complete, wait until running ones complete...
// 5000 finishes
// 2000 finishes
// Resolves, results are passed in given array order `[1000, 5000, 3000, 2000]`.

async function asyncPool(poolLimit, array, iteratorFn) {
  const ret = []; // 存儲(chǔ)所有的異步任務(wù)
  const executing = []; // 存儲(chǔ)正在執(zhí)行的異步任務(wù)
  for (const item of array) {
    // 調(diào)用iteratorFn函數(shù)創(chuàng)建異步任務(wù)
    const p = Promise.resolve().then(() => iteratorFn(item, array));
    ret.push(p); // 保存新的異步任務(wù)

    // 當(dāng)poolLimit值小于或等于總?cè)蝿?wù)個(gè)數(shù)時(shí)，進(jìn)行并發(fā)控制
    if (poolLimit <= array.length) {
      // 當(dāng)任務(wù)完成后，從正在執(zhí)行的任務(wù)數(shù)組中移除已完成的任務(wù)
      const e = p.then(() => executing.splice(executing.indexOf(e), 1));
      executing.push(e); // 保存正在執(zhí)行的異步任務(wù)
      if (executing.length >= poolLimit) {
        await Promise.race(executing); // 等待較快的任務(wù)執(zhí)行完成
      }
    }
  }
  return Promise.all(ret);
}

function asyncPool(poolLimit, array, iteratorFn) {
  let i = 0;
  const ret = []; // 存儲(chǔ)所有的異步任務(wù)
  const executing = []; // 存儲(chǔ)正在執(zhí)行的異步任務(wù)
  const enqueue = function () {
    if (i === array.length) {
      return Promise.resolve();
    }
    const item = array[i++]; // 獲取新的任務(wù)項(xiàng)
    const p = Promise.resolve().then(() => iteratorFn(item, array));
    ret.push(p);

    let r = Promise.resolve();

    // 當(dāng)poolLimit值小于或等于總?cè)蝿?wù)個(gè)數(shù)時(shí)，進(jìn)行并發(fā)控制
    if (poolLimit <= array.length) {
      // 當(dāng)任務(wù)完成后，從正在執(zhí)行的任務(wù)數(shù)組中移除已完成的任務(wù)
      const e = p.then(() => executing.splice(executing.indexOf(e), 1));
      executing.push(e);
      if (executing.length >= poolLimit) {
        r = Promise.race(executing); 
      }
    }
 
    // 正在執(zhí)行任務(wù)列表 中較快的任務(wù)執(zhí)行完成之后，才會(huì)從array數(shù)組中獲取新的待辦任務(wù)
    return r.then(() => enqueue());
  };
  return enqueue().then(() => Promise.all(ret));
}

Promise.all = function (iterators) {
  return new Promise((resolve, reject) => {
    if (!iterators || iterators.length === 0) {
      resolve([]);
    } else {
      let count = 0; // 計(jì)數(shù)器，用于判斷所有任務(wù)是否執(zhí)行完成
      let result = []; // 結(jié)果數(shù)組
      for (let i = 0; i < iterators.length; i++) {
        // 考慮到iterators[i]可能是普通對(duì)象，則統(tǒng)一包裝為Promise對(duì)象
        Promise.resolve(iterators[i]).then(
          (data) => {
            result[i] = data; // 按順序保存對(duì)應(yīng)的結(jié)果
            // 當(dāng)所有任務(wù)都執(zhí)行完成后，再統(tǒng)一返回結(jié)果
            if (++count === iterators.length) {
              resolve(result);
            }
          },
          (err) => {
            reject(err); // 任何一個(gè)Promise對(duì)象執(zhí)行失敗，則調(diào)用reject()方法
            return;
          }
        );
      }
    }
  });
};

Promise.race = function (iterators) {
  return new Promise((resolve, reject) => {
    for (const iter of iterators) {
      Promise.resolve(iter)
        .then((res) => {
          resolve(res);
        })
        .catch((e) => {
          reject(e);
        });
    }
  });
};