Async/await 是以更舒适的方式使用 promise 的一种特殊语法,同时它也非常易于理解和使用。

Async function

让我们以 async 这个关键字开始。它可以被放置在一个函数前面,如下所示:

  1. async function f() {
  2. return 1;
  3. }

在函数前面的 “async” 这个单词表达了一个简单的事情:即这个函数总是返回一个 promise。其他值将自动被包装在一个 resolved 的 promise 中。

例如,下面这个函数返回一个结果为 1 的 resolved promise,让我们测试一下:

  1. async function f() {
  2. return 1;
  3. }
  4. f().then(alert); // 1

……我们也可以显式地返回一个 promise,结果是一样的:

  1. async function f() {
  2. return Promise.resolve(1);
  3. }
  4. f().then(alert); // 1

所以说,async 确保了函数返回一个 promise,也会将非 promise 的值包装进去。很简单,对吧?但不仅仅这些。还有另外一个叫 await 的关键词,它只在 async 函数内工作,也非常酷。

Await

语法如下:

  1. // 只在 async 函数内工作
  2. let value = await promise;

关键字 await 让 JavaScript 引擎等待直到 promise 完成(settle)并返回结果。

这里的例子就是一个 1 秒后 resolve 的 promise:

  1. async function f() {
  2. let promise = new Promise((resolve, reject) => {
  3. setTimeout(() => resolve("done!"), 1000)
  4. });
  5. let result = await promise; // 等待,直到 promise resolve (*)
  6. alert(result); // "done!"
  7. }
  8. f();

这个函数在执行的时候,“暂停”在了 (*) 那一行,并在 promise settle 时,拿到 result 作为结果继续往下执行。所以上面这段代码在一秒后显示 “done!”。

让我们强调一下:await 字面的意思就是让 JavaScript 引擎等待直到 promise settle,然后以 promise 的结果继续执行。这个行为不会耗费任何 CPU 资源,因为引擎可以同时处理其他任务:执行其他脚本,处理事件等。

相比于 promise.then,它只是获取 promise 的结果的一个更优雅的语法,同时也更易于读写。

不能在普通函数中使用 await

如果我们尝试在非 async 函数中使用 await 的话,就会报语法错误:

  1. function f() {
  2. let promise = Promise.resolve(1);
  3. let result = await promise; // Syntax error
  4. }

如果函数前面没有 async 关键字,我们就会得到一个语法错误。就像前面说的,await 只在 async 函数 中有效。

让我们拿 Promise 链 那一章的 showAvatar() 例子,并将其改写成 async/await 的形式:

  1. 我们需要用 await 替换掉 .then 的调用。
  2. 另外,我们需要在函数前面加上 async 关键字,以使它们能工作。
  1. async function showAvatar() {
  2. // 读取我们的 JSON
  3. let response = await fetch('/article/promise-chaining/user.json');
  4. let user = await response.json();
  5. // 读取 github 用户信息
  6. let githubResponse = await fetch(`https://api.github.com/users/${user.name}`);
  7. let githubUser = await githubResponse.json();
  8. // 显示头像
  9. let img = document.createElement('img');
  10. img.src = githubUser.avatar_url;
  11. img.className = "promise-avatar-example";
  12. document.body.append(img);
  13. // 等待 3 秒
  14. await new Promise((resolve, reject) => setTimeout(resolve, 3000));
  15. img.remove();
  16. return githubUser;
  17. }
  18. showAvatar();

简洁明了,是吧?比之前可强多了。

await 不能在顶层代码运行

刚开始使用 await 的人常常会忘记 await 不能用在顶层代码中。例如,下面这样就不行:

  1. // 用在顶层代码中会报语法错误
  2. let response = await fetch('/article/promise-chaining/user.json');
  3. let user = await response.json();

但我们可以将其包裹在一个匿名 async 函数中,如下所示:

  1. (async () => {
  2. let response = await fetch('/article/promise-chaining/user.json');
  3. let user = await response.json();
  4. ...
  5. })();

await 接受 “thenables”

promise.then 那样,await 允许我们使用 thenable 对象(那些具有可调用的 then 方法的对象)。这里的想法是,第三方对象可能不是一个 promise,但却是 promise 兼容的:如果这些对象支持 .then,那么就可以对它们使用 await

这有一个用于演示的 Thenable 类,下面的 await 接受了该类的实例:

  1. class Thenable {
  2. constructor(num) {
  3. this.num = num;
  4. }
  5. then(resolve, reject) {
  6. alert(resolve);
  7. // 1000ms 后使用 this.num*2 进行 resolve
  8. setTimeout(() => resolve(this.num * 2), 1000); // (*)
  9. }
  10. };
  11. async function f() {
  12. // 等待 1 秒,之后 result 变为 2
  13. let result = await new Thenable(1);
  14. alert(result);
  15. }
  16. f();

如果 await 接收了一个非 promise 的但是提供了 .then 方法的对象,它就会调用这个 .then 方法,并将内建的函数 resolvereject 作为参数传入(就像它对待一个常规的 Promise executor 时一样)。然后 await 等待直到这两个函数中的某个被调用(在上面这个例子中发生在 (*) 行),然后使用得到的结果继续执行后续任务。

Class 中的 async 方法

要声明一个 class 中的 async 方法,只需在对应方法前面加上 async 即可:

  1. class Waiter {
  2. async wait() {
  3. return await Promise.resolve(1);
  4. }
  5. }
  6. new Waiter()
  7. .wait()
  8. .then(alert); // 1

这里的含义是一样的:它确保了方法的返回值是一个 promise 并且可以在方法中使用 await

Error 处理

如果一个 promise 正常 resolve,await promise 返回的就是其结果。但是如果 promise 被 reject,它将 throw 这个 error,就像在这一行有一个 throw 语句那样。

这个代码:

  1. async function f() {
  2. await Promise.reject(new Error("Whoops!"));
  3. }

……和下面是一样的:

  1. async function f() {
  2. throw new Error("Whoops!");
  3. }

在真实开发中,promise 可能需要一点时间后才 reject。在这种情况下,在 await 抛出(throw)一个 error 之前会有一个延时。

我们可以用 try..catch 来捕获上面提到的那个 error,与常规的 throw 使用的是一样的方式:

  1. async function f() {
  2. try {
  3. let response = await fetch('http://no-such-url');
  4. } catch(err) {
  5. alert(err); // TypeError: failed to fetch
  6. }
  7. }
  8. f();

如果有 error 发生,执行控制权马上就会被移交至 catch 块。我们也可以用 try 包装多行 await 代码:

  1. async function f() {
  2. try {
  3. let response = await fetch('/no-user-here');
  4. let user = await response.json();
  5. } catch(err) {
  6. // 捕获到 fetch 和 response.json 中的错误
  7. alert(err);
  8. }
  9. }
  10. f();

如果我们没有 try..catch,那么由异步函数 f() 的调用生成的 promise 将变为 rejected。我们可以在函数调用后面添加 .catch 来处理这个 error:

  1. async function f() {
  2. let response = await fetch('http://no-such-url');
  3. }
  4. // f() 变成了一个 rejected 的 promise
  5. f().catch(alert); // TypeError: failed to fetch // (*)

如果我们忘了在这添加 .catch,那么我们就会得到一个未处理的 promise error(可以在控制台中查看)。我们可以使用在 使用 promise 进行错误处理 一章中所讲的全局事件处理程序 unhandledrejection 来捕获这类 error。

async/awaitpromise.then/catch

当我们使用 async/await 时,几乎就不会用到 .then 了,因为 await 为我们处理了等待。并且我们使用常规的 try..catch 而不是 .catch。这通常(但不总是)更加方便。

但是当我们在代码的顶层时,也就是在所有 async 函数之外,我们在语法上就不能使用 await 了,所以这时候通常的做法是添加 .then/catch 来处理最终的结果(result)或掉出来的(falling-through)error,例如像上面那个例子中的 (*) 行那样。

async/await 可以和 Promise.all 一起使用

当我们需要同时等待多个 promise 时,我们可以用 Promise.all 把它们包装起来,然后使用 await

  1. // 等待结果数组
  2. let results = await Promise.all([
  3. fetch(url1),
  4. fetch(url2),
  5. ...
  6. ]);

如果出现 error,也会正常传递,从失败了的 promise 传到 Promise.all,然后变成我们能通过使用 try..catch 在调用周围捕获到的异常(exception)。

总结

函数前面的关键字 async 有两个作用:

  1. 让这个函数总是返回一个 promise。
  2. 允许在该函数内使用 await

Promise 前的关键字 await 使 JavaScript 引擎等待该 promise settle,然后:

  1. 如果有 error,就会抛出异常 — 就像那里调用了 throw error 一样。
  2. 否则,就返回结果。

这两个关键字一起提供了一个很好的用来编写异步代码的框架,这种代码易于阅读也易于编写。

有了 async/await 之后,我们就几乎不需要使用 promise.then/catch,但是不要忘了它们是基于 promise 的,因为有些时候(例如在最外层作用域)我们不得不使用这些方法。并且,当我们需要同时等待需要任务时,Promise.all 是很好用的。

任务

用 async/await 来重写

重写下面这个来自 Promise 链 一章的示例代码,使用 async/await 而不是 .then/catch

  1. function loadJson(url) {
  2. return fetch(url)
  3. .then(response => {
  4. if (response.status == 200) {
  5. return response.json();
  6. } else {
  7. throw new Error(response.status);
  8. }
  9. })
  10. }
  11. loadJson('no-such-user.json')
  12. .catch(alert); // Error: 404

解决方案

解析在代码下面:

  1. async function loadJson(url) { // (1)
  2. let response = await fetch(url); // (2)
  3. if (response.status == 200) {
  4. let json = await response.json(); // (3)
  5. return json;
  6. }
  7. throw new Error(response.status);
  8. }
  9. loadJson('no-such-user.json')
  10. .catch(alert); // Error: 404 (4)

解析:

  1. 将函数 loadJson 变为 async

  2. 将函数中所有的 .then 都替换为 await

  3. 我们可以返回 return response.json() 而不用等待它,像这样:

    1. if (response.status == 200) {
    2. return response.json(); // (3)
    3. }

    然后外部的代码就必须 await 这个 promise resolve。在本例中它无关紧要。

  4. loadJson 抛出的 error 被 .catch 处理了。在这儿我们我们不能使用 await loadJson(…),因为我们不是在一个 async 函数中。

使用 async/await 重写 “rethrow”

下面你可以看到来自 Promise 链 一章的 “rethrow” 例子。让我们来用 async/await 重写它,而不是使用 .then/catch

同时,我们可以在 demoGithubUser 中使用循环以摆脱递归:在 async/await 的帮助下很容易实现。

  1. class HttpError extends Error {
  2. constructor(response) {
  3. super(`${response.status} for ${response.url}`);
  4. this.name = 'HttpError';
  5. this.response = response;
  6. }
  7. }
  8. function loadJson(url) {
  9. return fetch(url)
  10. .then(response => {
  11. if (response.status == 200) {
  12. return response.json();
  13. } else {
  14. throw new HttpError(response);
  15. }
  16. })
  17. }
  18. // 询问用户名,直到 github 返回一个合法的用户
  19. function demoGithubUser() {
  20. let name = prompt("Enter a name?", "iliakan");
  21. return loadJson(`https://api.github.com/users/${name}`)
  22. .then(user => {
  23. alert(`Full name: ${user.name}.`);
  24. return user;
  25. })
  26. .catch(err => {
  27. if (err instanceof HttpError && err.response.status == 404) {
  28. alert("No such user, please reenter.");
  29. return demoGithubUser();
  30. } else {
  31. throw err;
  32. }
  33. });
  34. }
  35. demoGithubUser();

解决方案

这里没有什么技巧。只需要将 demoGithubUser 中的 .catch 替换为 try...catch,然后在需要的地方加上 async/await 即可:

  1. class HttpError extends Error {
  2. constructor(response) {
  3. super(`${response.status} for ${response.url}`);
  4. this.name = 'HttpError';
  5. this.response = response;
  6. }
  7. }
  8. async function loadJson(url) {
  9. let response = await fetch(url);
  10. if (response.status == 200) {
  11. return response.json();
  12. } else {
  13. throw new HttpError(response);
  14. }
  15. }
  16. // 询问用户名,直到 github 返回一个合法的用户
  17. async function demoGithubUser() {
  18. let user;
  19. while(true) {
  20. let name = prompt("Enter a name?", "iliakan");
  21. try {
  22. user = await loadJson(`https://api.github.com/users/${name}`);
  23. break; // 没有 error,退出循环
  24. } catch(err) {
  25. if (err instanceof HttpError && err.response.status == 404) {
  26. // 循环将在 alert 后继续
  27. alert("No such user, please reenter.");
  28. } else {
  29. // 未知的 error,再次抛出(rethrow)
  30. throw err;
  31. }
  32. }
  33. }
  34. alert(`Full name: ${user.name}.`);
  35. return user;
  36. }
  37. demoGithubUser();

在非 async 函数中调用 async 函数

我们有一个“普通”函数。如何在这个函数中调用 async 函数并使用其结果?

  1. async function wait() {
  2. await new Promise(resolve => setTimeout(resolve, 1000));
  3. return 10;
  4. }
  5. function f() {
  6. // ...这里怎么写?
  7. // 我们需要调用 async wait() 并等待以拿到结果 10
  8. // 记住,我们不能使用 "await"
  9. }

P.S. 这个任务其实很简单,但是对于 async/await 新手开发者来说,这个问题却很常见。

解决方案

在这种情况下,知道其内部工作原理会很有帮助。

只需要把 async 调用当作 promise 对待,并在它的后面加上 .then 即可:

  1. async function wait() {
  2. await new Promise(resolve => setTimeout(resolve, 1000));
  3. return 10;
  4. }
  5. function f() {
  6. // 1 秒后显示 10
  7. wait().then(result => alert(result));
  8. }
  9. f();