- Promise就是一个类,在执行这个类的时候需要传递一个执行器进去,执行器会立即执行
- Promise中有三种状态,分别为成功fulfilled、失败rejected以及等待pending
- pending -> fulfilled
- pending -> rejected
- resolve:fuifilled
- pending -> rejected
- resolve:fuifilled
- reject:rejected
- then方法内部做的事情就判断状态,如果状态是成功则调用成功的回调函数,如果状态是失败则调用失败的回调函数,then方式是被定义在原型对象中的
- then成功回调有一个参数,表示成功之后的值,then失败回调有一个参数,表示失败后的原因
- 同一个promise对象下面的then方法是可以被调用多次的
- then方法是可以被链式调用的, 后面then方法的回调函数拿到值的是上一个then方法的回调函数的返回值
const PENDING = "pending";const FULFILLED = "fulfilled";const REJECTED = "rejected";class MyPromise { constructor(executor) { try { executor(this.resolve, this.reject); } catch { this.reject(e); } } // promise 状态 status = PENDING; // 成功之后的值 value = undefined; // 失败之后的原因 reason = undefined; // 成功回调 successCallback = []; // 失败回调 failCallback = []; resolve = (value) => { // 如果状态不是等待,阻止代码向下执行 if (this.status !== PENDING) return; // 将状态变更为成功 this.status = FULFILLED; // 保存成功之后的值 this.value = value; // 判断成功回调是否存在,如果存在则调用 // this.successCallback && this.successCallback(this.value) while (this.successCallback.length) this.successCallback.shift()(); }; reject = (reason) => { // 如果状态不是等待,阻止代码向下执行 if (this.status !== PENDING) return; // 将状态变更为失败 this.status = REJECTED; // 保存失败之后的原因 this.reason = reason; // 判断失败回调是否存在,如果存在则调用 // this.failCallback && this.successCallback(this.reason) while (this.failCallback.length) this.failCallback.shift()(); }; then(successCallback, failCallback) { successCallback = successCallback ? successCallback : value => value failCallback = failCallback ? failCallback : reason => {throw reason} let promise2 = new MyPromise((resolve, reject) => { // 判断状态 if (this.status === FULFILLED) { setTimeout(() => { try { let x = successCallback(this.value); // 判断 x 的值是普通值还是promise对象 // 如果是普通值则直接调用resolve // 如果是promise对象,查看promise对象返回的结果 // 再根据promise对象返回的结果,决定调用resolve还是调用reject resolvePromise(promise2, x, resolve, reject); } catch(e) { reject(e); } }, 0); } else if (this.status === REJECTED) { setTimeout(() => { try { let x = failCallback(this.reason); // 判断 x 的值是普通值还是promise对象 // 如果是普通值则直接调用resolve // 如果是promise对象,查看promise对象返回的结果 // 再根据promise对象返回的结果,决定调用resolve还是调用reject resolvePromise(promise2, x, resolve, reject); } catch(e) { reject(e); } }, 0); } else { // 等待 // 将成功回调和失败回调存储起来 this.successCallback.push(() => { setTimeout(() => { try { let x = successCallback(this.value); // 判断 x 的值是普通值还是promise对象 // 如果是普通值则直接调用resolve // 如果是promise对象,查看promise对象返回的结果 // 再根据promise对象返回的结果,决定调用resolve还是调用reject resolvePromise(promise2, x, resolve, reject); } catch(e) { reject(e); } }, 0); }); this.failCallback.push(() => { setTimeout(() => { try { let x = failCallback(this.reason); // 判断 x 的值是普通值还是promise对象 // 如果是普通值则直接调用resolve // 如果是promise对象,查看promise对象返回的结果 // 再根据promise对象返回的结果,决定调用resolve还是调用reject resolvePromise(promise2, x, resolve, reject); } catch(e) { reject(e); } }, 0); }); } }); return promise2; }}function resolvePromise(promise2, x, resolve, reject) { if (promise2 === x) { return reject( new TypeError("Chaining cycle detected for promise #<Promise>") ); } if (x instanceof MyPromise) { // promise 对象 // x.then(value=>resolve(value),reason=>reject(reason)) x.then(resolve, reject); } else { // 普通值 resolve(x); }}module.exports = MyPromise;