利用async/await与forEach循环进行操作

Question

在使用 forEach 循环中使用 async/await 会有什么问题吗？我试图遍历一个文件数组，并在每个文件的内容上使用 await。

import fs from 'fs-promise'

async function printFiles () {
  const files = await getFilePaths() // 假设这个函数正常工作

  files.forEach(async (file) => {
    const contents = await fs.readFile(file, 'utf8')
    console.log(contents)
  })
}

printFiles()

这段代码确实可以工作，但是这样做会有什么问题吗？有人告诉我在像这样的高阶函数中不应该使用 async/await，所以我想问一下是否有任何问题。

Answer 1

使用ES2018，您可以大大简化上述所有答案：

async function printFiles () {
  const files = await getFilePaths()

  for await (const contents of files.map(file => fs.readFile(file, 'utf8'))) {
    console.log(contents)
  }
}

查看规范：proposal-async-iteration

简化后：

for await (const results of array) {
    await longRunningTask()
  }
  console.log('I will wait')

---

2018-09-10：最近这个答案引起了很多关注，请参阅Axel Rauschmayer的博客文章以获取有关异步迭代的更多信息。

Answer 2

当然，代码确实可以工作，但我很确定它不会按照你的期望工作。它只是触发了多个异步调用，但printFiles函数在此之后立即返回。

按顺序读取

如果你想按顺序读取文件，确实不能使用forEach。相反，你可以使用现代的for … of循环，其中await将按预期工作：

async function printFiles () {
  const files = await getFilePaths();

  for (const file of files) {
    const contents = await fs.readFile(file, 'utf8');
    console.log(contents);
  }
}

并行读取

如果你想并行读取文件，确实不能使用forEach。每个async回调函数调用都会返回一个promise，但你却将它们丢弃而不是等待它们。相反，你可以使用map，并使用Promise.all等待得到的promise数组：

async function printFiles () {
  const files = await getFilePaths();

  await Promise.all(files.map(async (file) => {
    const contents = await fs.readFile(file, 'utf8')
    console.log(contents)
  }));
}