在循环中使用async/有什么问题吗？我正在尝试遍历文件数组和每个文件的内容。awaitforEachawait
import fs from 'fs-promise'
async function printFiles () {
const files = await getFilePaths() // Assume this works fine
files.forEach(async (file) => {
const contents = await fs.readFile(file, 'utf8')
console.log(contents)
})
}
printFiles()
这段代码确实有效，但会不会有什么问题？有人告诉我你不应该在这样的高阶函数中使用async/ await，所以我只是想问问这是否有任何问题。
当然代码确实有效，但我很确定它不会做你期望它做的事情。它只是触发多个异步调用，但该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，您就可以等待您将获得的一系列PromisePromise.all：
async function printFiles () {
const files = await getFilePaths();
await Promise.all(files.map(async (file) => {
const contents = await fs.readFile(file, 'utf8')
console.log(contents)
}));
}
使用 ES2018，您可以大大简化上述所有答案：
async function printFiles () {
const files = await getFilePaths()
for await (const contents of files.map(file => fs.readFile(file, 'utf8'))) {
console.log(contents)
}
}
2018-09-10：这个答案最近受到了很多关注，有关异步迭代的更多信息，请参阅Axel Rauschmayer 的博客文章。
而不是Promise.all结合 with Array.prototype.map（它不保证Promises 被解析的顺序），我使用Array.prototype.reduce，从一个已解决的开始Promise：
async function printFiles () {
const files = await getFilePaths();
await files.reduce(async (promise, file) => {
// This line will wait for the last async function to finish.
// The first iteration uses an already resolved Promise
// so, it will immediately continue.
await promise;
const contents = await fs.readFile(file, 'utf8');
console.log(contents);
}, Promise.resolve());
}
npm 上的p-iterationmodule实现了 Array 迭代方法，因此它们可以通过 async/await 以非常简单的方式使用。
你的情况的一个例子：
const { forEach } = require('p-iteration');
const fs = require('fs-promise');
(async function printFiles () {
const files = await getFilePaths();
await forEach(files, async (file) => {
const contents = await fs.readFile(file, 'utf8');
console.log(contents);
});
})();
这里有一些forEachAsync原型。请注意，您需要使用await它们：
Array.prototype.forEachAsync = async function (fn) {
for (let t of this) { await fn(t) }
}
Array.prototype.forEachAsyncParallel = async function (fn) {
await Promise.all(this.map(fn));
}
请注意，虽然您可以将其包含在您自己的代码中，但您不应将其包含在您分发给其他人的库中（以避免污染他们的全局变量）。