1、什么是 promise?
Promise译为 “承诺”,是 JavaScript 中用于处理异步操作的解决方案。它代表一个异步操作的最终完成(或失败)及其结果值。
2、Promise 的特点
特点一:Promise 有三种状态。
pending:等待态,promise的初始状态fulfilled:成功态,promise调用resolve函数后即会从pending等待态变为fulfilled成功态。rejected:失败态:promise调用reject函数后即会从pending等待态变为rejected失败态
特点二:Promise 状态不可逆。
- promise的状态一旦发生变更,便无法再更改。比如调用
resolve从pending变为fulfilled,它的状态就永远是fulfilled了,再调用reject也无法从fulfilled变成rejected。 - 并且状态只能从
pending变为fulfilled或rejected,不能从fulfilled或rejected返回到pending,这个也很好理解,状态只能前进不能倒退。
特点三:支持链式调用。
- 通过
.then()、.catch()、.finally()等方法进行链式调用。
3、Promise 手写流程
先看用法:
constp=newPromise((resolve,reject)=>{resolve(111);})p.then((value)=>{console.log(value)},(error)=>{console.log(error)})首先,Promise肯定是一个类,所以我们才可以new它,然后Promise实例化的时候给它传入一个回调我们叫它executor方法,Promise内部会立即调用这个executor方法,并且会传入resolve和reject两个函数作为调用参数,另外在Promise类的原型上应该提供一个then方法,它里面可以传入两个回调,分别为Promise成功的回调和Promise失败的回调。调用resolve后会走入成功的回调中,调用reject后会走入失败的回调中。
3.1 版本一:搭建整体架子
constPENDING='pending'constFULFILLED='fulfilled'constREJECTED='rejected'classPromise{constructor(executor){this.value=undefinedthis.reason=undefinedthis.status=PENDINGconstresolve=(value)=>{if(this.status===PENDING){this.value=valuethis.status=FULFILLED}}constreject=(reason)=>{if(this.status===PENDING){this.reason=reasonthis.status=REJECTED}}executor(resolve,reject);}then(onFulfilled,onRejected){if(this.status===FULFILLED){onFulfilled&&onFulfilled(this.value)}if(this.status===REJECTED){onRejected&&onRejected(this.reason)}}}module.exports=Promise;3.2 版本二:支持异步的 resolve 或者 reject
如果是异步调用 resolve 或者 reject ,那么上面onFulfilled和onRejected将无法执行了。
constp=newPromise((resolve,reject)=>{setTimeout(()=>{resolve(111);},1000)})p.then((value)=>{console.log(value)},(error)=>{console.log(error)})所以我们需用两个数组充当队列把then里边的回调存起来。
classPromise{constructor(executor){// ...// 定义两个数组this.onResolvedCallbacks=[];this.onRejectedCallbacks=[];constresolve=(value)=>{if(this.status===PENDING){this.value=valuethis.status=FULFILLEDthis.onResolvedCallbacks.forEach(fn=>fn())}}constreject=(reason)=>{if(this.status===PENDING){this.reason=reasonthis.status=REJECTEDthis.onRejectedCallbacks.forEach(fn=>fn())}}// 默认执行executor函数,并传入resolve和reject函数executor(resolve,reject)}then(onFulfilled,onRejected){if(this.status===FULFILLED){onFulfilled&&onFulfilled(this.value)}if(this.status===REJECTED){onRejected&&onRejected(this.reason)}if(this.status===PENDING){this.onResolvedCallbacks.push(()=>{onFulfilled(this.value)})this.onRejectedCallbacks.push(()=>{onRejected(this.reason)})}}}这里定义了两个数组onResolvedCallbacks和onRejectedCallbacks分别存储 then 里面成功的回调和失败的回调,然后再调用resolve和reject时分别循环执行这两个数组里存储的回调函数。
3.3 版本三:支持 Promise 链式调用
比如:下面这段代码:
constp=newPromise((resolve,reject)=>{setTimeout(()=>{resolve(111)},1000)})p.then((value1)=>{console.log('value1',value1)return222},(error1)=>{console.log('error1',error1)}).then((value2)=>{console.log('value2',value2)},(error2)=>{console.log('error2',error2)})它的打印结果为:
这个是如何实现的呢?
这个其实也简单,它内部调用then方法时,返回了一个新的promise,并让这个新的promise接管了它下一个then方法。
注意:这里不能返回
this,这样会导致多个then方法全部受同一个promise控制。
classPromise{// ...then(onFulfilled,onRejected){constpromise2=newPromise((resolve,reject)=>{if(this.status===FULFILLED){// onFulfilled方法可能返回值或者promiseconstx=onFulfilled(this.value)resolvePromise(promise2,x,resolve,reject)}if(this.status===REJECTED){// onRejected方法可能返回值或者promiseconstx=onRejected(this.reason)resolvePromise(promise2,x,resolve,reject)}if(this.status===PENDING){this.onResolvedCallbacks.push(()=>{constx=onFulfilled(this.value)resolvePromise(promise2,x,resolve,reject)})this.onRejectedCallbacks.push(()=>{constx=onRejected(this.reason)resolvePromise(promise2,x,resolve,reject)})}})returnpromise2}}最核心的就是resolvePromise,来看下它做了什么:
functionresolvePromise(promise2,x,resolve,reject){if(promise2===x){returnreject(newTypeError('UnhandledPromiseRejectionWarning: TypeError: Chaining cycle detected for promise #<Promise>'))}letcalled// 判断x的类型 x是对象或函数才有可能是一个promiseif(typeofx==='object'&&x!==null||typeofx==='function'){try{constthen=x.thenif(typeofthen==='function'){// 只能认为它是一个promisethen.call(x,(y)=>{if(called)returncalled=trueresolvePromise(promise2,y,resolve,reject)},(r)=>{if(called)returncalled=truereject(r)})}else{resolve(x)}}catch(e){if(called)returncalled=truereject(e)}}else{resolve(x)}}- 首先,先判断新返回的一个promise
promise2是不是等于x,抛出错误UnhandledPromiseRejectionWarning: TypeError: Chaining cycle detected for promise #<Promise>,这一步是防止内部的循环引用。 - 声明一个变量
called,相当于加了一把锁,让promise只能调用一次成功或者失败回调,防止死循环。 - 解析x,如果它的类型是
object并且不为null,或者它是一个函数,并且它有then方法,我们认为这是一个promise - 递归解析,
then里面再次调用resolvePromise
3.4 版本四:模拟异步微任务
因为promise在EventLoop里面是个微任务,不过我们可以简单通过setTimeout模拟。
然后我们再加上一些报错的捕获代码以及一些参数的兼容代码,以及实现catch方法。
classPromise{constructor(executor){// ...// 这里增加try catchtry{executor(resolve,reject)}catch(e){reject(e)}}then(onFulfilled,onRejected){// 这里兼容下 onFulfilled 和 onRejected 的传参onFulfilled=typeofonFulfilled==='function'?onFulfilled:v=>v onRejected=typeofonRejected==='function'?onRejected:err=>{throwerr}constpromise2=newPromise((resolve,reject)=>{if(this.status===FULFILLED){// 用 setTimeout 模拟异步setTimeout(()=>{try{constx=onFulfilled(this.value)resolvePromise(promise2,x,resolve,reject)}catch(e){reject(e)}},0)}if(this.status===REJECTED){// 用 setTimeout 模拟异步setTimeout(()=>{try{constx=onRejected(this.reason)resolvePromise(promise2,x,resolve,reject)}catch(e){reject(e)}},0)}if(this.status===PENDING){this.onResolvedCallbacks.push(()=>{// 用 setTimeout 模拟异步setTimeout(()=>{try{constx=onFulfilled(this.value)resolvePromise(promise2,x,resolve,reject)}catch(e){reject(e)}},0)})this.onRejectedCallbacks.push(()=>{// 用 setTimeout 模拟异步setTimeout(()=>{try{constx=onRejected(this.reason)resolvePromise(promise2,x,resolve,reject)}catch(e){reject(e)}},0)})}})returnpromise2}// catch函数实际上里面就是调用了then方法catch(errCallback){returnthis.then(null,errCallback)}}executor执行时增加try catch,防止执行用户传入的函数直接就报错了,这时我们应该直接rejectpromise。- 调用
onFulfilled和onRejected时,需要包裹setTimeout。 catch函数实际上里面就是调用了then方法,然后第一个参数传null。
ok,这样就写的差不多了。最后我们来测试下我们写的promise是否符合规范。
4、测试 promise,使其符合 Promises/A+ 规范
promise是有规范的,即Promises/A+,我们可以跑一段脚本测试写的promise是否符合规范。
首先,需要在我们的promise增加如下代码:
// 测试脚本Promise.defer=Promise.deferred=function(){letdfd={}dfd.promise=newPromise((resolve,reject)=>{dfd.resolve=resolve dfd.reject=reject})returndfd}然后安装promises-aplus-tests包,比如用npm可以使用命令npm install -g promises-aplus-tests安装到全局,然后使用命令promises-aplus-tests 文件名即可进行测试,里面有872测试用例,全部通过即可以认为这是一个标准的promise。
测试全部通过,大功告成了!