promise就是构造函数
使用是发布订阅模式
我们定义三个状态
// pending
const PENDING = "pending"
// 成功的回调状态
const FULFILLED = "fulfilled"
// 失败的回调状态
const REJECTED = "rejected"
代码里面的注释，可以看下
class Promise {
constructor(executor) {
this.status = PENDING
// 成功传递的参数
this.value = undefined
// 失败传递的参数
this.reson = undefined
// 用来存放成功的函数
this.resolveCall = []
// 用来存放失败的函数
this.rejectCall = []
let resolve = (value) => {
// 保证只在pending状态时调用
if (this.status === PENDING) {
this.status = FULFILLED
this.value = value
// 成功的发布
this.resolveCall.forEach((fn=> {
fn()
}))
}
}
let reject = (reson) => {
if (this.status === PENDING) {
this.status = REJECTED
this.reson = reson
// 失败的发布
this.rejectCall.forEach((fn=> {
fn()
}))
}
}
// try catch 的作用保证 throw 抛出错误时调用reject函数
try {
executor(resolve, reject)
} catch (error) {
reject(error)
}
}
// new Promise后调用这个方法
then(onResolve, onReject) {
if (this.status === FULFILLED) {
onResolve(this.value)
}
if (this.status === REJECTED) {
onReject(this.reson)
}
// 这个是处理异步的方法
if(this.status === PENDING) {
// 成功的订阅
this.resolveCall.push(()=> {
onResolve(this.value)
})
// 失败的订阅
this.rejectCall.push(()=> {
onReject(this.reson)
})
}
}
}
module.exports = Promise
这里有一点可能会有一点难以理解
p.then调用后 this.status === PENDING 其实就是宏观任务最后执行
关于这个异步调用可能有一点难以理解的， 加强一下事件循环机制就好了
let Promise = require('./promise.js')
let p = new Promise((resolve, reject) => {
// reject('error')
// resolve('value')
// throw new Error('报错了')
setTimeout(() => {
resolve('value')
}, 1000);
})
p.then((success) => {
console.log(success);
}, (err) => {
// console.log(err);
})
参考视频源码链接
https://www.bilibili.com/video/BV1LE411G7mS?p=2
