等待 VS Promise.all

IT技术 javascript node.js promise async-await for-await
2021-02-21 02:07:07

这有什么区别吗:

const promises = await Promise.all(items.map(e => somethingAsync(e)));
for (const res of promises) {
  // do some calculations
}

还有这个 ?

for await (const res of items.map(e => somethingAsync(e))) {
  // do some calculations
}

我知道在第一个片段中,所有的 Promise 都会同时触发,但我不确定第二个片段。for 循环是否等待第一次迭代完成以调用下一个 promise ?还是所有的 Promise 都是同时触发的,循环内部就像是它们的回调?

4个回答

是的,它们完全不同。for await应该与异步迭代器一起使用,而不是与预先存在的Promise数组一起使用。

只是为了说明,

for await (const res of items.map(e => somethingAsync(e))) …

工作原理与

const promises = items.map(e => somethingAsync(e));
for await (const res of promises) …

或者

const promises = [somethingAsync(items[0]), somethingAsync(items[1]), …];
for await (const res of promises) …

somethingAsync呼叫将立即发生,一次全部,任何等待之前。然后,它们await一个接一个地编辑,如果它们中的任何一个被拒绝,这绝对是一个问题:这将导致未处理的Promise拒绝错误。使用Promise.all是处理 promise 数组的唯一可行选择

for (const res of await Promise.all(promises)) …

请参阅等待多个并发等待操作等待 Promise.all() 和多个等待之间有什么区别?详情。

好的,将使用Promise.all,感谢您的澄清
2021-04-16 02:07:07
IMO 一系列Promise被同化为异步迭代器,因为它们将控制权交还给事件循环,对吗?如果在我的somethingAsync函数中,我正确地捕获了所有内容怎么办?
2021-04-20 02:07:07
是的,该数组提供了一个异步迭代器,这就是循环不会抛出协议错误的原因。但该迭代一次等待一个Promise,忽略数组中后面Promise的错误。当然,如果somethingAsync从不出错,就不会发生任何不好的事情,但这很难保证。使用for awaitPromise的阵列上仍然是一个不好的做法。
2021-04-26 02:07:07

for await ...当在异步迭代器上当前迭代的计算依赖于一些先前的迭代时,就需要出现。如果没有依赖,Promise.all就是你的选择。for await构造旨在与异步迭代器一起使用,尽管 - 在您的示例中,您可以将它与一系列Promise一起使用。

有关使用无法使用以下方法重写的异步迭代器的示例,请参阅javascript.info书中的示例分页数据Promise.all

(async () => {
  for await (const commit of fetchCommits('javascript-tutorial/en.javascript.info')) {
    console.log(commit.author.login);
  }
})();

这里fetchCommits异步迭代器向fetchGitHub 存储库的提交发出请求fetch与30个提交一个JSON响应,并且还提供了一个链接到下一个页面Link标题。因此下一次迭代只能在上一次迭代有下一个请求的链接后开始

async function* fetchCommits(repo) {
  let url = `https://api.github.com/repos/${repo}/commits`;

  while (url) {
    const response = await fetch(url, { 
      headers: {'User-Agent': 'Our script'}, 
    });

    const body = await response.json(); // (array of commits

    // The URL of the next page is in the headers, extract it using a regexp
    let nextPage = response.headers.get('Link').match(/<(.*?)>; rel="next"/);
    nextPage = nextPage?.[1];

    url = nextPage;

    for(let commit of body) { // yield commits one by one, until the page ends
      yield commit;
    }
  }
}
很清楚,谢谢。在您的代码示例中,for await行为像yield*不是吗?因为每次迭代都会产生多个项目
2021-04-17 02:07:07
没有生成器组合,只有yield每次提交。每 30 次迭代后,就会加载一个新页面,并yield编辑接下来的 30 次提交迭代之间的依赖实际上每三十次才发生一次
2021-04-25 02:07:07

正如您所说,Promise.all将一次性发送所有请求,然后在所有请求都完成后您将收到响应。

在第二种情况下,您将一次发送请求,但逐一接收响应。

请参阅此小示例以供参考。

let i = 1;
function somethingAsync(time) {
  console.log("fired");
  return delay(time).then(() => Promise.resolve(i++));
}
const items = [1000, 2000, 3000, 4000];

function delay(time) {
  return new Promise((resolve) => { 
      setTimeout(resolve, time)
  });
}

(async() => {
  console.time("first way");
  const promises = await Promise.all(items.map(e => somethingAsync(e)));
  for (const res of promises) {
    console.log(res);
  }
  console.timeEnd("first way");

  i=1; //reset counter
  console.time("second way");
  for await (const res of items.map(e => somethingAsync(e))) {
    // do some calculations
    console.log(res);
  }
  console.timeEnd("second way");
})();

你也可以在这里尝试 - https://repl.it/repls/SuddenUselessAnalyst

希望这可以帮助。

事实上,你证明了我的第二点。使用for await实际上同时触发所有Promise,因此循环的执行时间:4 秒。如果它等待下一个完成,则总执行时间将为 1+2+3+4 = 10 秒。
2021-05-13 02:07:07
这是真的。添加了时间部分来证明这一点。
2021-05-14 02:07:07

实际上,使用for await语法确实会立即触发所有Promise。

一小段代码证明了这一点:

const sleep = s => {
  return new Promise(resolve => {
    setTimeout(resolve, s * 1000);
  });
}

const somethingAsync = async t => {
  await sleep(t);
  return t;
}

(async () => {
  const items = [1, 2, 3, 4];
  const now = Date.now();
  for await (const res of items.map(e => somethingAsync(e))) {
    console.log(res);
  }
  console.log("time: ", (Date.now() - now) / 1000);
})();

标准输出: time: 4.001

但循环内部并不“作为回调”。如果我反转数组,所有日志都会立即出现。我想Promise会立即触发,运行时只是等待第一个解决方案进入下一次迭代。

编辑:实际上,for await当我们将它与异步迭代器以外的其他东西一起使用时,使用是不好的做法,最好是使用Promise.all,根据@Bergi 在他的回答中的说法。