一、基本概念

1-1 什么是Promise?

  • Promise 是异步编程的一种解决方案,简单说就是一个容器,里面保存着某个未来才会结束的事件(通常是一个异步操作)的结果。从语法上说,Promise 是一个对象,从它可以获取异步操作的消息;从本意上讲,它是承诺,承诺它过一段时间会给你一个结果
  • Promise 是异步编程的一种解决方案,比传统的异步解决方案【回调函数】和【事件】更合理、更强大。现已被 ES6 纳入进规范中。

    1-2 Promise三种状态

  • pending:在过程中还没有结果,pending状态不会触发then和catch

  • fulfiled:成功;fulfiled状态会触发后续的then回调函数
  • rejected:失败;rejected状态会触发后续的catch回调函数

    1-3 Promise作用

  • Promise可以解决异步的问题(但Promise本身不是异步的)

  • Promise可以解决回调地狱,代码难以维护
  • Promise可以支持多个并发的请求,获取并发请求中的数据

    二、Promise使用

    Promise是一个构造函数,自身有all、reject、resolve这几个方法,原型上有then、catch等方法
    Promise的构造函数接收一个参数:函数,并且这个函数需要传入两个参数:resolve 异步操作执行成功后的回调函数
    ,reject 异步操作执行失败后的回调函数

    2-1 Promise.prototype.then

  • 实质上,Promise的精髓是“状态”,用维护状态、传递状态的方式来使得回调函数能够及时调用,它比传递callback函数要简单、灵活的多

  • 当Promise的触发resolve方法时,状态变为fulfiled,触发reject方法时,状态变为rejected
  • then是Promise实例的方法,then方法可以接受两个参数,第一个指定resolve的回调,第二个指定reject的回调 ```javascript let p = new Promise((resolve, reject) => { setTimeout(function(){ var num = Math.ceil(Math.random()*10); //生成1-10的随机数 if(num <= 5){
    1. resolve(num);
    } else{
    1. reject('数字太大了');
    } }, 2000); }); p.then((data) => { console.log(‘resolved’,data); },(err) => { console.log(‘rejected’,err); });
  1. <a name="JClMI"></a>
  2. #### 2-2 Promise.prototype.catch
  3. - Promise实例的catch方法和then方法的第二个参数作用一样,都是指定reject的回调
  4. - 但是catch方法有另外一个作用,就是在执行resolve的回调(也就是then方法中的第一个参数)时,如果代码出错抛出异常了,那么并不会报错卡死,而是会进到这个catch方法中,与try/catch语句有相同的功能
  5. ```javascript
  6. p.then((data) => {
  7. console.log('resolved',data);
  8. console.log(somedata); //此处的somedata未定义
  9. })
  10. .catch((err) => {
  11. console.log('rejected',err); // rejected somedata is not defined
  12. });

2-3 Promise.all

  • all是Promise的类方法,用于将多个Promise实例,包装成一个新的Promise实例
  • all方法提供了并行执行异步操作的能力,并且在所有异步操作执行完后才执行回调 ```javascript let Promise1 = new Promise(function(resolve, reject){}) let Promise2 = new Promise(function(resolve, reject){}) let Promise3 = new Promise(function(resolve, reject){})

let p = Promise.all([Promise1, Promise2, Promise3])

p.then(funciton(){ // 三个Promise对象的状态都变成fulfilled,p的状态才会变成fulfilled }, function(){ // 只要三个Promise对象有其中一个状态变成rejected,p的状态就变成rejected })

  1. Promise.all 源码实现
  2. ```javascript
  3. Promise.myAll = (promises) => {
  4. return new Promise((resolve, reject) => {
  5. // 计数器
  6. let count = 0
  7. // 存放结果
  8. let result = []
  9. const len = promises.length
  10. if (len === 0) {
  11. return resolve([])
  12. }
  13. promises.forEach((p, i) => {
  14. // 注意有的数组项有可能不是Promise,需要手动转化一下
  15. Promise.resolve(p).then((res) => {
  16. count += 1
  17. // 收集每个Promise的返回值
  18. result[ i ] = res
  19. // 当所有的Promise都成功了,那么将返回的Promise结果设置为result
  20. if (count === len) {
  21. resolve(result)
  22. }
  23. // 监听数组项中的Promise catch只要有一个失败,那么我们自己返回的Promise也会失败
  24. }).catch(reject)
  25. })
  26. })
  27. }
  28. // 测试一下
  29. const p1 = Promise.resolve(1)
  30. const p2 = new Promise((resolve) => {
  31. setTimeout(() => resolve(2), 1000)
  32. })
  33. const p3 = new Promise((resolve) => {
  34. setTimeout(() => resolve(3), 3000)
  35. })
  36. const p4 = Promise.reject('err4')
  37. const p5 = Promise.reject('err5')
  38. // 1. 所有的Promise都成功了
  39. const p11 = Promise.myAll([ p1, p2, p3 ])
  40. .then(console.log) // [ 1, 2, 3 ]
  41. .catch(console.log)
  42. // 2. 有一个Promise失败了
  43. const p12 = Promise.myAll([ p1, p2, p4 ])
  44. .then(console.log)
  45. .catch(console.log) // err4
  46. // 3. 有两个Promise失败了,可以看到最终输出的是err4,第一个失败的返回值
  47. const p13 = Promise.myAll([ p1, p4, p5 ])
  48. .then(console.log)
  49. .catch(console.log) // err4
  50. // 与原生的Promise.all返回是一致的

2-4 Promise.race

  • race是Promise的类方法,用法就是谁跑的快,以谁为准执行回调
  • race的使用场景,可以用作给某个异步请求设置超时时间,并且在超时后执行相应的操作
    1. //请求某个图片资源
    2. function requestImg(){
    3. var p = new Promise((resolve, reject) => {
    4. var img = new Image();
    5. img.onload = function(){
    6. resolve(img);
    7. }
    8. img.src = '图片的路径';
    9. });
    10. return p;
    11. }
    12. //延时函数,用于给请求计时
    13. function timeout(){
    14. var p = new Promise((resolve, reject) => {
    15. setTimeout(() => {
    16. reject('图片请求超时');
    17. }, 5000);
    18. });
    19. return p;
    20. }
    21. Promise.race([requestImg(), timeout()]).then((data) =>{
    22. console.log(data);
    23. }).catch((err) => {
    24. console.log(err);
    25. });
    代码解析:requestImg函数会异步请求一张图片,这里把地址写为”图片的路径”,所以肯定是无法成功请求到的。timeout函数是一个延时5秒的异步操作。我们把这两个返回Promise对象的函数放进race,于是他俩就会赛跑,如果5秒之内图片请求成功了,那么遍进入then方法,执行正常的流程。如果5秒钟图片还未成功返回,那么timeout就跑赢了,则进入catch,报出“图片请求超时”的信息。

    2-5 Promise.resolve

    Promise.resolve(value)返回一个以 value 值解析后的 Promise 对象 ```javascript // 情况1 value 本身就是 Promise 对象,则该对象作为 Promise.resolve 方法的返回值返回 function fn(resolve){ setTimeout(function(){
    1. resolve(123);
    },3000); } let p0 = new Promise(fn) let p1 = Promise.resolve(p0) console.log(p1) // Promise {} console.log(p1) // Promise {: 123}

// 情况2 value 是个 thenable(即带有 then 方法),返回 thenable 的最终状态 let p = Promise.resolve($.ajax(‘/test/test.json’)) p.then(function(value){ console.log(value); });

// 情况2 value 是普通值 let p = Promise.resolve(123) console.log(p) // Promise {: 123}

  1. Promise.resolve(value) 源码实现
  2. ```javascript
  3. Promise.myResolve = function (value) {
  4. // 是Promise实例,直接返回即可
  5. if (value && typeof value === 'object' && (value instanceof Promise)) {
  6. return value
  7. }
  8. // 否则其他情况一律再通过Promise包装一下
  9. return new Promise((resolve) => {
  10. resolve(value)
  11. })
  12. }
  13. // 测试一下,还是用刚才的例子
  14. // 1. 非Promise对象,非thenable对象
  15. Promise.myResolve(1).then(console.log) // 1
  16. // 2. Promise对象成功状态
  17. const p2 = new Promise((resolve) => resolve(2))
  18. Promise.myResolve(p2).then(console.log) // 2
  19. // 3. Promise对象失败状态
  20. const p3 = new Promise((_, reject) => reject('err3'))
  21. Promise.myResolve(p3).catch(console.error) // err3
  22. // 4. thenable对象
  23. const p4 = {
  24. then (resolve) {
  25. setTimeout(() => resolve(4), 1000)
  26. }
  27. }
  28. Promise.myResolve(p4).then(console.log) // 4
  29. // 5. 啥都没传
  30. Promise.myResolve().then(console.log) // undefined

三、根据promiseA+ 实现 Promise

3-1 实现成功和失败的回调方法

  • 首先,需要创建一个Promise类,在使用的时候传入了一个执行器executor,executor会传入两个参数:成功(resolve)和失败(reject)

    1. class Promise {
    2. constructor (executor){
    3. //默认状态是等待状态
    4. this.status = 'panding';
    5. this.value = undefined;
    6. this.reason = undefined;
    7. //存放成功的回调
    8. this.onResolvedCallbacks = [];
    9. //存放失败的回调
    10. this.onRejectedCallbacks = [];
    11. let resolve = (data) => {
    12. if(this.status === 'pending'){ //this指的是实例
    13. this.value = data;
    14. this.status = "resolved";
    15. this.onResolvedCallbacks.forEach(fn => fn());
    16. }
    17. }
    18. let reject = (reason) => {
    19. if(this.status === 'pending'){
    20. this.reason = reason;
    21. this.status = 'rejected';
    22. this.onRejectedCallbacks.forEach(fn => fn());
    23. }
    24. }
    25. // promise A+规范规定,在有异常错误时,则执行失败函数。
    26. try{//执行时可能会发生异常
    27. executor(resolve,reject);
    28. }catch (e){
    29. reject(e);//promise失败了
    30. }
    31. }


    3-2 then方法链式调用

  • 把每次调用resolve的结果存入一个数组中,每次调用reject的结果存入一个数组。这就是为何会在上面定义两个数组,且分别在resolve()和reject()遍历两个数组的原因。因此,在调用resolve()或者reject()之前,如果在pending状态时,会把多次then中的结果存入数组中

    1. then(onFulFilled, onRejected) {
    2. if (this.status === 'resolved') {
    3. onFulFilled(this.value);
    4. }
    5. if (this.status === 'rejected') {
    6. onRejected(this.reason);
    7. }
    8. // 当前既没有完成 也没有失败
    9. if (this.status === 'pending') {
    10. // 存放成功的回调
    11. this.onResolvedCallbacks.push(() => {
    12. onFulFilled(this.value);
    13. });
    14. // 存放失败的回调
    15. this.onRejectedCallbacks.push(() => {
    16. onRejected(this.reason);
    17. });
    18. }
    19. }
  • Promise A+规范中规定then方法可以链式调用,在Promise中,要实现链式调用返回的结果是返回一个新的promise,第一次then中返回的结果,无论是成功或失败,都将返回到下一次then中的成功态中,但在第一次then中如果抛出异常错误,则将返回到下一次then中的失败态中

  • 链式调用成功会返回值,有多种情况,根据举的例子,大致列出可能会发生的结果。因此将链式调用返回的值单独写一个方法。方法中传入四个参数,分别是p2,x,resolve,reject,其中p2指的是上一次返回的promise,x表示运行promise返回的结果,resolve和reject是p2的方法。则代码写为:
    1. function resolvePromise(promise2,x,resolve,reject){
    2. //判断x是不是promise
    3. //规范中规定:我们允许别人乱写,这个代码可以实现我们的promise和别人的promise 进行交互
    4. if(promise2 === x){//不能自己等待自己完成
    5. return reject(new TypeError('循环引用'));
    6. };
    7. // x是除了null以外的对象或者函数
    8. if(x !=null && (typeof x === 'object' || typeof x === 'function')){
    9. let called;//防止成功后调用失败
    10. try{//防止取then是出现异常 object.defineProperty
    11. let then = x.then;//取x的then方法 {then:{}}
    12. if(typeof then === 'function'){//如果then是函数就认为他是promise
    13. //call第一个参数是this,后面的是成功的回调和失败的回调
    14. then.call(x,y => {//如果Y是promise就继续递归promise
    15. if(called) return;
    16. called = true;
    17. resolvePromise(promise2,y,resolve,reject)
    18. },r => { //只要失败了就失败了
    19. if(called) return;
    20. called = true;
    21. reject(r);
    22. });
    23. }else{//then是一个普通对象,就直接成功即可
    24. resolve(x);
    25. }
    26. }catch (e){
    27. if(called) return;
    28. called = true;
    29. reject(e)
    30. }
    31. }else{//x = 123 x就是一个普通值 作为下个then成功的参数
    32. resolve(x)
    33. }
    34. }

    3-3 完整 PromiseA+ 源码

    ```javascript function resolvePromise(promise2,x,resolve,reject){ //判断x是不是promise //规范中规定:我们允许别人乱写,这个代码可以实现我们的promise和别人的promise 进行交互 if(promise2 === x){//不能自己等待自己完成
    1. return reject(new TypeError('循环引用'));
    }; // x是除了null以外的对象或者函数 if(x !=null && (typeof x === ‘object’ || typeof x === ‘function’)){
    1. let called;//防止成功后调用失败
    2. try{//防止取then是出现异常 object.defineProperty
    3. let then = x.then;//取x的then方法 {then:{}}
    4. if(typeof then === 'function'){//如果then是函数就认为他是promise
    5. //call第一个参数是this,后面的是成功的回调和失败的回调
    6. then.call(x,y => {//如果Y是promise就继续递归promise
    7. if(called) return;
    8. called = true;
    9. resolvePromise(promise2,y,resolve,reject)
    10. },r => { //只要失败了就失败了
    11. if(called) return;
    12. called = true;
    13. reject(r);
    14. });
    15. }else{//then是一个普通对象,就直接成功即可
    16. resolve(x);
    17. }
    18. }catch (e){
    19. if(called) return;
    20. called = true;
    21. reject(e)
    22. }
    }else{//x = 123 x就是一个普通值 作为下个then成功的参数
    1. resolve(x)
    }

}

class Promise { constructor (executor){ //默认状态是等待状态 this.status = ‘panding’; this.value = undefined; this.reason = undefined; //存放成功的回调 this.onResolvedCallbacks = []; //存放失败的回调 this.onRejectedCallbacks = []; let resolve = (data) => { if(this.status === ‘pending’){ this.value = data; this.status = “resolved”; this.onResolvedCallbacks.forEach(fn => fn()); } } let reject = (reason) => { if(this.status === ‘pending’){ this.reason = reason; this.status = ‘rejected’; this.onRejectedCallbacks.forEach(fn => fn()); } } try{ //执行时可能会发生异常 executor(resolve,reject); }catch (e){ reject(e); //promise失败了 }

  1. }
  2. then(onFuiFilled,onRejected){
  3. //防止值得穿透
  4. onFuiFilled = typeof onFuiFilled === 'function' ? onFuiFilled : y => y;
  5. onRejected = typeof onRejected === 'function' ? onRejected :err => {throw err;}
  6. let promise2;//作为下一次then方法的promise
  7. if(this.status === 'resolved'){
  8. promise2 = new Promise((resolve,reject) => {
  9. setTimeout(() => {
  10. try{
  11. //成功的逻辑 失败的逻辑
  12. let x = onFuiFilled(this.value);
  13. //看x是不是promise 如果是promise取他的结果 作为promise2成功的的结果
  14. //如果返回一个普通值,作为promise2成功的结果
  15. //resolvePromise可以解析x和promise2之间的关系
  16. //在resolvePromise中传入四个参数,第一个是返回的promise,第二个是返回的结果,第三个和第四个分别是resolve()和reject()的方法。
  17. resolvePromise(promise2,x,resolve,reject)
  18. }catch(e){
  19. reject(e);
  20. }
  21. },0)
  22. });
  23. }
  24. if(this.status === 'rejected'){
  25. promise2 = new Promise((resolve,reject) => {
  26. setTimeout(() => {
  27. try{
  28. let x = onRejected(this.reason);
  29. //在resolvePromise中传入四个参数,第一个是返回的promise,第二个是返回的结果,第三个和第四个分别是resolve()和reject()的方法。
  30. resolvePromise(promise2,x,resolve,reject)
  31. }catch(e){
  32. reject(e);
  33. }
  34. },0)
  35. });
  36. }
  37. //当前既没有完成也没有失败
  38. if(this.status === 'pending'){
  39. promise2 = new Promise((resolve,reject) => {
  40. //把成功的函数一个个存放到成功回调函数数组中
  41. this.onResolvedCallbacks.push( () =>{
  42. setTimeout(() => {
  43. try{
  44. let x = onFuiFilled(this.value);
  45. resolvePromise(promise2,x,resolve,reject);
  46. }catch(e){
  47. reject(e);
  48. }
  49. },0)
  50. });
  51. //把失败的函数一个个存放到失败回调函数数组中
  52. this.onRejectedCallbacks.push( ()=>{
  53. setTimeout(() => {
  54. try{
  55. let x = onRejected(this.reason);
  56. resolvePromise(promise2,x,resolve,reject)
  57. }catch(e){
  58. reject(e)
  59. }
  60. },0)
  61. })
  62. })
  63. }
  64. return promise2;//调用then后返回一个新的promise
  65. }
  66. catch (onRejected) {
  67. // catch 方法就是then方法没有成功的简写
  68. return this.then(null, onRejected);
  69. }

} Promise.all = function (promises) { //promises是一个promise的数组 return new Promise(function (resolve, reject) { let arr = []; //arr是最终返回值的结果 let i = 0; // 表示成功了多少次 function processData(index, data) { arr[index] = data; if (++i === promises.length) { resolve(arr); } } for (let i = 0; i < promises.length; i++) { promises[i].then(function (data) { processData(i, data) }, reject) } }) } // 只要有一个promise成功了 就算成功。如果第一个失败了就失败了 Promise.race = function (promises) { return new Promise((resolve, reject) => { for (var i = 0; i < promises.length; i++) { promises[i].then(resolve,reject) } }) } // 生成一个成功的promise Promise.resolve = function(value){ return new Promise((resolve,reject) => resolve(value); } // 生成一个失败的promise Promise.reject = function(reason){ return new Promise((resolve,reject) => reject(reason)); } Promise.defer = Promise.deferred = function () { let dfd = {}; dfd.promise = new Promise( (resolve, reject) => { dfd.resolve = resolve; dfd.reject = reject; }); return dfd } module.exports = Promise;

```