如何在回调中使用等待？

Question

我的代码是：

async function run() {
  await sleep(1);
  fs.readFile('list.txt', 'utf8', function (err, text) {
    console.log(text);
    await sleep(5);
   });
}

run();

await sleep(1) 很好，但 await sleep(5) 会导致：

SyntaxError: async 只在 async 函数中有效

fs.readFile 有问题吗？在这种情况下如何使用await？

以上是要测试的简化示例。在我的实际使用中，我需要将await sleep 放在一个回调中，深度嵌套在几个异步函数中。

Answer 1

我不确定sleep 正在做什么，但您的问题正在发生，因为fs.readfile 的回调不是异步函数，而await sleep(5) 就是在那里。

async function run() {
    await sleep(1);
    fs.readFile('list.txt', 'utf8', function (err, text) {
    console.log(text);           /* ^this isn't an async function */
    await sleep(5);
    });
}

您可以通过将异步函数作为回调传递来消除该错误，但是不建议混合使用 Promise 和回调流，这会导致问题，尤其是在处理错误时。它可以防止您从run() 之外的内部等待中链接承诺并捕获错误。

更好的方法是将fs.readFile() 包装在一个promise 中并等待它。

async function run() {
  await sleep(1);
  const text = await new Promise((resolve, reject) => {
    fs.readFile('list.txt', 'utf8', function (err, text) {
      if (err) reject(err) else resolve(text);
    });
  });
  console.log(text);
  await sleep(5);
}

这将使您能够以更强大的方式捕获任何错误：

run()
.then(() => /*...*/)
.catch(err => /* handle error */

并避免未经处理的拒绝。

Answer 2

以上是要测试的简化示例。在我的实际使用中，我需要将 await sleep 放在一个回调中，深度嵌套在几个异步函数中。

当有机会遵守承诺时，不应使用async..await 或一般承诺来扩充基于回调的 API（如果多次调用回调，则可能无法实现）。这会导致糟糕的控制流和错误处理。

一旦run 内部有async 回调函数，就不可能将嵌套的promise 与run().then(...) 链接起来。来自嵌套 Promise 的错误也可能未处理并导致 UnhandledPromiseRejectionWarning。

正确的方法是从回调转移到 Promise 并使用 Promise 控制流。通常这可以通过 promise 构造函数来实现：

async function run() {
  await sleep(1);
  const text = await new Promise((resolve, reject) => {
    fs.readFile('list.txt', 'utf8', function (err, text) {
      if (err) reject(err) else resolve(text);
    });
  });
  console.log(text);
  await sleep(5);
}

有numerous ways 可以从基于节点回调的 API 中获取承诺，例如fs 从 Node 10 开始提供 promise API：

async function run() {
  await sleep(1);
  const text = await fs.promises.readFile('list.txt', 'utf8');
  console.log(text);
  await sleep(5);
}

Answer 3

如果您的函数包含“await”，您必须在函数声明前加上“async”。

注意：通过使您的函数成为“异步”函数，承诺会始终返回。因此，如果您返回一个字符串，该字符串将自动包装在一个 Promise 对象中。

因此，您可以手动返回 Promise（为清楚起见）。一个简单的已解决承诺就足够了：

async function foo(){
    await bar();
    return Promise.resolve('optional'); // optionally resolve with a value
}

关键字“async”总是在关键字“function”之前：

var foo = async function(){
    await bar();
    return Promise.resolve('optional'); // optionally resolve with a value
}

... 以及箭头函数：

var foo = sally( async () => {
    await bar();
    return Promise.resolve('optional'); // optionally resolve with a value
})

获取返回值：

foo().then(val => console.log(val) ); // prints "optional" to console

Answer 4

您必须在功能启动前使用 aysnc 键。 等待关键字 无法正常使用。

async function run() {
  await sleep(1);
  fs.readFile('list.txt', 'utf8', async function (err, text) {
    console.log(text);
    await sleep(5);
   });
}

run();