Async:简洁优雅的异步之道

前言

在异步处理方案中,目前最为简洁优雅的便是async函数(以下简称A函数)。经过必要的分块包装后,A函数能使多个相关的异步操作如同同步操作一样聚合起来,使其相互间的关系更为清晰、过程更为简洁、调试更为方便。它本质是Generator函数的语法糖,通俗的说法是使用G函数进行异步处理的增强版。

龙亭ssl适用于网站、小程序/APP、API接口等需要进行数据传输应用场景,ssl证书未来市场广阔!成为成都创新互联公司的ssl证书销售渠道,可以享受市场价格4-6折优惠!如果有意向欢迎电话联系或者加微信:028-86922220(备注:SSL证书合作)期待与您的合作!

尝试

学习A函数必须有Promise基础,***还了解Generator函数,有需要的可查看延伸小节。

为了直观的感受A函数的魅力,下面使用Promise和A函数进行了相同的异步操作。该异步的目的是获取用户的留言列表,需要分页,分页由后台控制。具体的操作是:先获取到留言的总条数,再更正当前需要显示的页数(每次切换到不同页时,总数目可能会发生变化),***传递参数并获取到相应的数据。

 
 
 
  1. let totalNum = 0; // Total comments number. 
  2. let curPage = 1; // Current page index. 
  3. let pageSize = 10; // The number of comment displayed in one page. 
  4. // 使用A函数的主代码。 
  5. async function dealWithAsync() { 
  6. totalNum = await getListCount(); 
  7. console.log('Get count', totalNum);
  8. if (pageSize * (curPage - 1) > totalNum) { 
  9. curPage = 1; 
  10. return getListData(); 
  11. // 使用Promise的主代码。 
  12. function dealWithPromise() { 
  13. return new Promise((resolve, reject) => { 
  14. getListCount().then(res => { 
  15. totalNum = res; 
  16. console.log('Get count', res); 
  17. if (pageSize * (curPage - 1) > totalNum) { 
  18. curPage = 1; 
  19. return getListData() 
  20. }).then(resolve).catch(reject); 
  21. }); 
  22. // 开始执行dealWithAsync函数。 
  23. // dealWithAsync().then(res => { 
  24. // console.log('Get Data', res) 
  25. // }).catch(err => { 
  26. // console.log(err); 
  27. // }); 
  28. // 开始执行dealWithPromise函数。 
  29. // dealWithPromise().then(res => { 
  30. // console.log('Get Data', res) 
  31. // }).catch(err => { 
  32. // console.log(err); 
  33. // }); 
  34. function getListCount() {
  35. return createPromise(100).catch(() => { 
  36. throw 'Get list count error'; 
  37. }); 
  38. function getListData() { 
  39. return createPromise([], { 
  40. curPage: curPage, 
  41. pageSize: pageSize, 
  42. }).catch(() => { 
  43. throw 'Get list data error'; 
  44. }); 
  45. function createPromise( 
  46. data, // Reback data 
  47. params = null, // Request params 
  48. isSucceed = true, 
  49. timeout = 1000, 
  50. ) { 
  51. return new Promise((resolve, reject) => { 
  52. setTimeout(() => { 
  53. isSucceed ? resolve(data) : reject(data); 
  54. }, timeout); 
  55. }); 

对比dealWithAsync和dealWithPromise两个简单的函数,能直观的发现:使用A函数,除了有await关键字外,与同步代码无异。而使用Promise则需要根据规则增加很多包裹性的链式操作,产生了太多回调函数,不够简约。另外,这里分开了每个异步操作,并规定好各自成功或失败时传递出来的数据,近乎实际开发。

1 登堂

1.1 形式

A函数也是函数,所以具有普通函数该有的性质。不过形式上有两点不同:一是定义A函数时,function关键字前需要有async关键字(意为异步),表示这是个A函数。二是在A函数内部可以使用await关键字(意为等待),表示会将其后面跟随的结果当成异步操作并等待其完成。

以下是它的几种定义方式。

 
 
 
  1. // 声明式 
  2. async function A() {} 
  3. // 表达式 
  4. let A = async function () {}; 
  5. // 作为对象属性 
  6. let o = { 
  7. A: async function () {} 
  8. }; 
  9. // 作为对象属性的简写式 
  10. let o = { 
  11. async A() {} 
  12. }; 
  13. // 箭头函数 
  14. let o = { 
  15. A: async () => {} 
  16. }; 

1.2 返回值

执行A函数,会固定的返回一个Promise对象。

得到该对象后便可监设置成功或失败时的回调函数进行监听。如果函数执行顺利并结束,返回的P对象的状态会从等待转变成成功,并输出return命令的返回结果(没有则为undefined)。如果函数执行途中失败,JS会认为A函数已经完成执行,返回的P对象的状态会从等待转变成失败,并输出错误信息。

 
 
 
  1. // 成功执行案例 
  2. A1().then(res => { 
  3. console.log('执行成功', res); // 10 
  4. }); 
  5. async function A1() { 
  6. let n = 1 * 10; 
  7. return n; 
  8. // 失败执行案例 
  9. A2().catch(err => { 
  10. console.log('执行失败', err); // i is not defined. 
  11. }); 
  12. async function A2() { 
  13. let n = 1 * i; 
  14. return n; 

1.3 await

只有在A函数内部才可以使用await命令,存在于A函数内部的普通函数也不行。

引擎会统一将await后面的跟随值视为一个Promise,对于不是Promise对象的值会调用Promise.resolve()进行转化。即便此值为一个Error实例,经过转化后,引擎依然视其为一个成功的Promise,其数据为Error的实例。

当函数执行到await命令时,会暂停执行并等待其后的Promise结束。如果该P对象最终成功,则会返回成功的返回值,相当将await xxx替换成返回值。如果该P对象最终失败,且错误没有被捕获,引擎会直接停止执行A函数并将其返回对象的状态更改为失败,输出错误信息。

***,A函数中的return x表达式,相当于return await x的简写。

 
 
 
  1. // 成功执行案例 
  2. A1().then(res => { 
  3. console.log('执行成功', res); // 约两秒后输出100。 
  4. }); 
  5. async function A1() { 
  6. let n1 = await 10; 
  7. let n2 = await new Promise(resolve => { 
  8. setTimeout(() => { 
  9. resolve(10); 
  10. }, 2000); 
  11. }); 
  12. return n1 * n2; 
  13. // 失败执行案例 
  14. A2().catch(err => { 
  15. console.log('执行失败', err); // 约两秒后输出10。 
  16. }); 
  17. async function A2() { 
  18. let n1 = await 10; 
  19. let n2 = await new Promise((resolve, reject) => { 
  20. setTimeout(() => { 
  21. reject(10); 
  22. }, 2000); 
  23. }); 
  24. return n1 * n2;

2 入室

2.1 继发与并发

对于存在于JS语句(for, while等)的await命令,引擎遇到时也会暂停执行。这意味着可以直接使用循环语句处理多个异步。

以下是处理继发的两个例子。A函数处理相继发生的异步尤为简洁,整体上与同步代码无异。

 
 
 
  1. // 两个方法A1和A2的行为结果相同,都是每隔一秒输出10,输出三次。 
  2. async function A1() { 
  3. let n1 = await createPromise(); 
  4. console.log('N1', n1); 
  5. let n2 = await createPromise(); 
  6. console.log('N2', n2); 
  7. let n3 = await createPromise(); 
  8. console.log('N3', n3); 
  9. async function A2() { 
  10. for (let i = 0; i< 3; i++) { 
  11. let n = await createPromise(); 
  12. console.log('N' + (i + 1), n); 
  13. function createPromise() { 
  14. return new Promise(resolve => { 
  15. setTimeout(() => { 
  16. resolve(10); 
  17. }, 1000); 
  18. }); 

接下来是处理并发的三个例子。A1函数使用了Promise.all生成一个聚合异步,虽然简单但灵活性降低了,只有都成功和失败两种情况。A3函数相对A2仅仅为了说明应该怎样配合数组的遍历方法使用async函数。重点在A2函数的理解上。

A2函数使用了循环语句,实际是继发的获取到各个异步值,但在总体的时间上相当并发(这里需要好好理解一番)。因为一开始创建reqs数组时,就已经开始执行了各个异步,之后虽然是逐一继发获取,但总花费时间与遍历顺序无关,恒等于耗时最多的异步所花费的时间(不考虑遍历、执行等其它的时间消耗)。

 
 
 
  1. // 三个方法A1, A2和A3的行为结果相同,都是在约一秒后输出[10, 10, 10]。 
  2. async function A1() {
  3. let res = await Promise.all([createPromise(), createPromise(), createPromise()]); 
  4. console.log('Data', res); 
  5. async function A2() { 
  6. let res = []; 
  7. let reqs = [createPromise(), createPromise(), createPromise()]; 
  8. for (let i = 0; i< reqs.length; i++) { 
  9. res[i] = await reqs[i]; 
  10. console.log('Data', res); 
  11. async function A3() { 
  12. let res = []; 
  13. let reqs = [9, 9, 9].map(async (item) => { 
  14. let n = await createPromise(item); 
  15. return n + 1; 
  16. }); 
  17. for (let i = 0; i< reqs.length; i++) { 
  18. res[i] = await reqs[i]; 
  19. console.log('Data', res); 
  20. function createPromise(n = 10) { 
  21. return new Promise(resolve => { 
  22. setTimeout(() => { 
  23. resolve(n); 
  24. }, 1000); 
  25. }); 

2.2 错误处理

一旦await后面的Promise转变成rejected,整个async函数便会终止。然而很多时候我们不希望因为某个异步操作的失败,就终止整个函数,因此需要进行合理错误处理。注意,这里所说的错误不包括引擎解析或执行的错误,仅仅是状态变为rejected的Promise对象。

处理的方式有两种:一是先行包装Promise对象,使其始终返回一个成功的Promise。二是使用try.catch捕获错误。

 
 
 
  1. // A1和A2都执行成,且返回值为10。 
  2. A1().then(console.log); 
  3. A2().then(console.log); 
  4. async function A1() { 
  5. let n; 
  6. n = await createPromise(true); 
  7. return n; 
  8. async function A2() { 
  9. let n; 
  10. try { 
  11. n = await createPromise(false); 
  12. } catch (e) { 
  13. n = e; 
  14. return n; 
  15. function createPromise(needCatch) { 
  16. let p = new Promise((resolve, reject) => { 
  17. reject(10); 
  18. }); 
  19. return needCatch ? p.catch(err => err) : p; 

2.3 实现原理

前言中已经提及,A函数是使用G函数进行异步处理的增强版。既然如此,我们就从其改进的方面入手,来看看其基于G函数的实现原理。A函数相对G函数的改进体现在这几个方面:更好的语义,内置执行器和返回值是Promise。

更好的语义。G函数通过在function后使用*来标识此为G函数,而A函数则是在function前加上async关键字。在G函数中可以使用yield命令暂停执行和交出执行权,而A函数是使用await来等待异步返回结果。很明显,async和await更为语义化。

 
 
 
  1. // G函数 
  2. function* request() { 
  3. let n = yield createPromise(); 
  4. // A函数 
  5. async function request() { 
  6. let n = await createPromise(); 
  7. function createPromise() { 
  8. return new Promise(resolve => { 
  9. setTimeout(() => { 
  10. resolve(10); 
  11. }, 1000); 
  12. }); 

内置执行器。调用A函数便会一步步自动执行和等待异步操作,直到结束。如果需要使用G函数来自动执行异步操作,需要为其创建一个自执行器。通过自执行器来自动化G函数的执行,其行为与A函数基本相同。可以说,A函数相对G函数***改进便是内置了自执行器。

 
 
 
  1. // 两者都是每隔一秒钟打印出10,重复两次。 
  2. // A函数 
  3. A(); 
  4. async function A() { 
  5. let n1 = await createPromise(); 
  6. console.log(n1); 
  7. let n2 = await createPromise(); 
  8. console.log(n2); 
  9. // G函数,使用自执行器执行。 
  10. spawn(G); 
  11. function* G() { 
  12. let n1 = yield createPromise(); 
  13. console.log(n1);
  14. let n2 = yield createPromise(); 
  15. console.log(n2); 
  16. function spawn(genF) { 
  17. return new Promise(function(resolve, reject) { 
  18. const gen = genF(); 
  19. function step(nextF) { 
  20. let next; 
  21. try { 
  22. next = nextF(); 
  23. } catch(e) { 
  24. return reject(e); 
  25. if(next.done) { 
  26. return resolve(next.value); 
  27. Promise.resolve(next.value).then(function(v) { 
  28. step(function() { return gen.next(v); }); 
  29. }, function(e) { 
  30. step(function() { return gen.throw(e); }); 
  31. }); 
  32. step(function() { return gen.next(undefined); }); 
  33. }); 
  34. function createPromise() { 
  35. return new Promise(resolve => { 
  36. setTimeout(() => {
  37. resolve(10); 
  38. }, 1000); 
  39. }); 

2.4 执行顺序

在了解A函数内部与包含它外部间的执行顺序前,需要明白两点:一为Promise的实例方法是推迟到本轮事件末尾才执行的后执行操作,详情请查看链接。二为Generator函数是通过调用实例方法来切换执行权进而控制程序执行顺序,详情请查看链接。理解好A函数的执行顺序,能更加清楚的把握此三者的存在。

先看以下代码,对比A1、A2和A3方法的结果。

 
 
 
  1. F(A1); // 接连打印出:1 3 4 2 5。
  2. F(A2); // 接连打印出:1 3 2 4 5。
  3. F(A3); // 先打印出:1 3 2,隔两秒后打印出:4 9。
  4. function F(A) { 
  5. console.log(1); 
  6. A().then(console.log); 
  7. console.log(2); 
  8. async function A1() { 
  9. console.log(3); 
  10. console.log(4); 
  11. return 5; 
  12. async function A2() { 
  13. console.log(3); 
  14. let n = await 5; 
  15. console.log(4); 
  16. return n; 
  17. async function A3() { 
  18. console.log(3); 
  19. let n = await createPromise(); 
  20. console.log(4); 
  21. return n; 
  22. function createPromise() { 
  23. return new Promise(resolve => { 
  24. setTimeout(() => { 
  25. resolve(9); 
  26. }, 2000); 
  27. }); 

从结果上可归纳出一些表面形态。执行A函数,会即刻执行其函数体,直到遇到await命令。遇到await命令后,执行权会转向A函数外部,即不管A函数内部执行而开始执行外部代码。执行完外部代码(本轮事件)后,才继续执行之前await命令后面的代码。

归纳到此已成功一半,之后着手分析其成因。如果客官您对本楼有所了解,那一定不会忘记‘自执行器’这位大婶吧?估计是忘记了。A函数的本质就是带有自执行器的G函数,所以探究A函数的执行原理就是探究使用自执行器的G函数的执行原理。想起了?

再看下面代码,使用相同逻辑的G函数会得到与A函数相同的结果。

 
 
 
  1. F(A); // 先打印出:1 3 2,隔两秒后打印出:4 9。 
  2. F(() => { 
  3. return spawn(G); 
  4. }); // 先打印出:1 3 2,隔两秒后打印出:4 9。 
  5. function F(A) { 
  6. console.log(1); 
  7. A().then(console.log); 
  8. console.log(2); 
  9. async function A() { 
  10. console.log(3); 
  11. let n = await createPromise(); 
  12. console.log(4); 
  13. return n; 
  14. function* G() { 
  15. console.log(3); 
  16. let n = yield createPromise(); 
  17. console.log(4); 
  18. return n; 
  19. function createPromise() { 
  20. return new Promise(resolve => { 
  21. setTimeout(() => { 
  22. resolve(9); 
  23. }, 2000); 
  24. }); 
  25. function spawn(genF) { 
  26. return new Promise(function(resolve, reject) { 
  27. const gen = genF(); 
  28. function step(nextF) { 
  29. let next; 
  30. try {
  31.  next = nextF(); 
  32. } catch(e) { 
  33. return reject(e); 
  34. if(next.done) { 
  35. return resolve(next.value); 
  36. Promise.resolve(next.value).then(function(v) { 
  37. step(function() { return gen.next(v); }); 
  38. }, function(e) { 
  39. step(function() { return gen.throw(e); }); 
  40. }); 
  41. }
  42. step(function() { return gen.next(undefined); }); 
  43. }); 

自动执行G函数时,遇到yield命令后会使用Promise.resolve包裹其后的表达式,并为其设置回调函数。无论该Promise是立刻有了结果还是过某段时间之后,其回调函数都会被推迟到在本轮事件末尾执行。之后再是下一步,再下一步。同样的道理适用于A函数,当遇到await命令时(此处略去三五字),所以有了如此这般的执行顺序。谢幕。

分享题目:Async:简洁优雅的异步之道
文章链接:http://www.mswzjz.cn/qtweb/news9/108009.html

攀枝花网站建设、攀枝花网站运维推广公司-贝锐智能,是专注品牌与效果的网络营销公司;服务项目有等

广告

声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 贝锐智能