为什么执行不会在 await (async/await JS) 处停止？

Question

我正在编写一个函数，它应该尽可能快地执行所有异步函数，但是，其中只有 5 个可以同时运行。

我想使用Promise.race 来实现，所以实现不是最好的。问题是代码执行不会在await 处停止。我希望，counter 变量只有在承诺解决但不等待承诺解决时才会减少。代码也不会停在Promise.all，这让我觉得我对 Promise 的理解是不正确的。代码如下，有问题的函数是runPromises。

async function runPromises(promises, limit) {
  const LIMIT = limit || 10;
  let promsCopy = promises.slice();
  let counter = 0;
  let queue = [];
  while (promsCopy.length !== 0) {
    if (counter < LIMIT) {
      let prom = promsCopy.shift();
      if (prom) {
        queue.push(prom());
        counter += 1;
        if (counter >= LIMIT) {
          let [completed] = await Promise.race(
            queue.map((p) => p.then((_) => [p]))
          );
          queue.splice(queue.indexOf(completed), 1);
          counter -= 1;
        }
      }
    }
  }
  await Promise.all(queue);
}

// the code below is just for testing

const asyncFuncLong = () => {
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      resolve();
    }, 6000);
  });
};

const asyncFuncShort = () => {
  return new Promise((resolve, reject) => {
    setTimeout(() => {
      resolve();
    }, 1000);
  });
};

let fns = [
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
  asyncFuncLong,
];

let start = Date.now();

runPromises(fns, 10).then(() => {
  console.log(Date.now() - start);
});

编辑：已修复。现在一切正常。谢谢两位！

Answer 1

fns 数组是一个函数列表。这些函数返回 Promise 对象。然后，您将该函数列表传递给您的 runPromises 函数，该函数似乎想要将 Promise 对象列表作为参数。但是你传递给它一个函数列表。

我的建议是

• 更改runPromises 函数，使其在某个时刻实际调用prom()（或仅使用映射，如const r = await Promise.all(queue.map((fn) => { return fn(); }));），或

• 将fns 的定义更改为let fns = [ asyncFuncLong(), asyncFuncShort(), asyncFuncLong(), ... ];。