回答

参考代码

<script type="text/javascript">
 const fn = (t) => {
  // 用setTimeout模拟异步请求
  return new Promise((resolve, react) => {
      setTimeout(() => {
          console.log('任务完成', t, new Date());
          resolve({ t, date: new Date() });
      }, t * 1000);
  })
};

let arr = [1, 1, 1, 2, 2, 2, 3, 3, 3]

/**
 * arrs 请求数据源数组
 * limit 是每次并行发起多少个请求
 * handleFn 就是异步处理函数
*/
function limitQueueFn(arrs, limit, handleFn) {
  // 完成任务数
  let runningIndex = 0; // 这是正在执行的下标
  let finishedIndex = 0 // 这是已经执行完的下表
  let result = new Array(arrs.length).fill(0) // 建立一个空数组， 存储结果
  return new Promise((resolveFn, rejectFn) => {
    // 第一次的时候 一次性执行 limit 个任务
    for (let i = 0; i < limit; i++) {
      run();
    }
    // 执行一个任务
    function run() {
        // 构造待执行任务 当该任务完成后 如果还有待完成的任务 继续执行任务
        new Promise((resolve, reject) => {
            const value = arrs[runningIndex];
            runningIndex++; // 这个是同步操作
            resolve(handleFn(value))
        }).then((res) => {
            result[finishedIndex] = res
            finishedIndex++
            if (runningIndex < arrs.length) {
              run()
            } else { // 全部执行完毕
              resolveFn(result)
            }
        })
    }
  })
};

limitQueueFn(arr, 3, fn).then(res => {
  console.log('结果如下：')
  console.log(res)
})
 </script>