万字详解JavaScript手写一个Promise

2023-06-20 原文

前言

手写Promise现在已经成了面试的热门内容，但在实际开发中基本都不会去手写一个Promise，但是在面试中各种手写题可能就会遇到一个手写Promise，我们可以尽量提高我们的上限，从而获取更多的工作机会。

Promise核心原理实现

首先我们从使用的角度来分析一下Promise，然后编写一个最简单版本的Promise。

Promise的使用分析

Promise就是一个类，在执行这个类的时候，需要传递一个执行器(回调函数)进去，执行器会立即执行。

Promise中的状态分为三个，分别是：

pending→等待
fulfilled→成功
rejected→失败

状态的切换只有两种，分别是：

pending→fulfilled
pending→rejected

一旦状态发生改变，就不会再次改变：

执行器中的两个参数，分别是resolve和reject，其实就是两个回调函数，调用resolve是从pending状态到fulfilled，调用reject是从状态pending到rejected。传递给这两个回调函数的参数会作为成功或失败的值。
Promise的实例对象具有一个then方法，该方法接受两个回调函数，分别来处理成功与失败的状态，then方法内部会进行判断，然后根据当前状态确定调用的回调函数。then方法应该是被定义在原型对象中的。
then的回调函数中都包含一个值，如果是成功，表示成功后返回的值；如果是失败就表示失败的原因。

MyPromise的实现

根据我们上面的分析，写出如下代码：

MyPromise.js
// 定义所有状态的常量
const PENDING = 'pending'
const FULFILLED = 'fulfilled'
const REJECTED = 'rejected'
// Promise实质上就是一个类，首先创建一个Promise的类
class MyPromise {
    // 实例化Promise时需要一个回调函数，该回调函数立即执行
    constructor(executor) {
        // 在调用executor需要传递两个回调函数，分别是resolve和reject
        executor(this.resolve, this.reject)
    }
    // Promise 的状态
    status = PENDING
    // 记录成功与失败的值
    value = undefined
    reason = undefined
    resolve = (value) => {// 这里使用箭头函数是为了使其内部的this指向为该实例化后的对象
        // 形参value表示，调用resolve时传递的参数
        // 如果当前状态不是pending，就直接跳出该逻辑
        if (this.status !== PENDING) return

        // 将状态修改为成功
        this.status = FULFILLED

        // 将传入的值进行保存
        this.value = value
    }
    reject = (reason) => {// 这里使用箭头函数是为了使其内部的this指向为该实例化后的对象
        // 形参reason表示，调用reject时传递的失败的原因
        // 如果当前状态不是pending，就直接跳出该逻辑
        if (this.status !== PENDING) return

        // 将状态修改为失败
        this.status = REJECTED

        // 保存失败的原因
        this.reason = reason
    }
    // then方法的实现
    then (onFulfilled, onRejected) {
        // 判断当前状态,根据状态调用指定回调
        if (this.status === FULFILLED) {
            // 将成功的值作为参数返回
            onFulfilled(this.value)
        } else if (this.status === REJECTED) {
            // 将失败的原因作为参数返回
            onRejected(this.reason)
        }
    }
}
// 导出Promise
module.exports = MyPromise

现在我们就来写一段代码验证一下上面的代码

验证resolve：

const MyPromise = require('./myPromise')

let promise = new MyPromise((resolve, reject) => {
    resolve('成功')
})
promise.then(value => {
    console.log(value);
}, reason => {
    console.log(reason);
})
/* 输出
    成功
*/

验证reject：

const MyPromise = require('./myPromise')
let promise = new MyPromise((resolve, reject) => {
    reject('失败')
})
promise.then(value => {
    console.log(value);
}, reason => {
    console.log(reason);
})
/* 输出
    失败
*/

验证状态不可变：

const MyPromise = require('./myPromise')
let promise = new MyPromise((resolve, reject) => {
    resolve('成功')
    reject('失败')
})
promise.then(value => {
    console.log(value);
}, reason => {
    console.log(reason);
})
/* 输出
    成功
*/

在Promise中加入异步操作

如果我们的代码中存在异步操作，我们自己写的Promise将毫无用处，

例如下面这段代码：

const MyPromise = require('./myPromise')
let promise = new MyPromise((resolve, reject) => {
    setTimeout(resolve, 2000, '成功')
})
promise.then(value => {
    console.log(value);
}, reason => {
    console.log(reason);
})

这段代码2000ms后没有任何输出，为了解决这个问题我们将对自己编写的类进行如下操作：

创建两个实例方法用于存储我们传入的成功与失败的处理逻辑。
为then方法添加状态为pending时的处理逻辑，这时将传递进来的属性保存到实例上。
在成功或者失败时调用相应的传递进来的回调函数(实例属性存在函数的情况下)。

实现代码如下：

// MyPromise.js
const PENDING = 'pending'
const FULFILLED = 'fulfilled'
const REJECTED = 'rejected'
class MyPromise {
    constructor(executor) {
        executor(this.resolve, this.reject)
    }
    status = PENDING
    value = undefined
    reason = undefined
    // 存储成功与失败的处理逻辑
    onFulfilled = undefined
    onRejected = undefined
    resolve = (value) => {
        if (this.status !== PENDING) return
        this.status = FULFILLED
        this.value = value
        // 如果将状态修复为成功，调用成功的回调
        this.onFulfilled && this.onFulfilled(this.value)
    }
    reject = (reason) => {
        if (this.status !== PENDING) return
        this.status = REJECTED
        this.reason = reason
        // 如果将状态修复为失败，调用失败的回调
        this.onRejected && this.onRejected(this.reason)
    }
    then (onFulfilled, onRejected) {
        if (this.status === FULFILLED) {
            onFulfilled(this.value)
        } else if (this.status === REJECTED) {
            onRejected(this.reason)
        } else {
            // 表示既不是成功，也不是失败。这个时候保存传递进来的两个回调
            this.onFulfilled = onFulfilled
            this.onRejected = onRejected
        }
    }
}
module.exports = MyPromise

这里的this.onFulfilled && this.onFulfilled(this.value)表示如果该属性存在就调用这个方法。

现在我们重新执行一开始上面那一段代码，2s后会成功输出成功。

实现then方法的多次调用

Promise实例中存在要给then方法，允许我们在Promise实例中链式调用，每个then方法还会返回一个Promise实例，

如下图所示：

Promise实例方法then是可以多次进行调用，而我们现在自己封装的却执行调用一次，现在根据新需要来重新改写我们的代码，

实现思路如下：

定义可以存储多个回调的数组，用于存储多个回调函数。
如果是同步执行的代码，执行后立即知道执行结果，所以可以直接调用回调函数。
如果是异步代码，需要将每次回调函数保存到数组中，然后状态变化时依次调用函数。

实现代码如下：

// MyPromise.js
const PENDING = 'pending'
const FULFILLED = 'fulfilled'
const REJECTED = 'rejected'
class MyPromise {
    constructor(executor) {
        executor(this.resolve, this.reject)
    }
    status = PENDING
    value = undefined
    reason = undefined
    // 存储成功与失败的处理逻辑
    onFulfilled = []
    onRejected = []

    resolve = (value) => {
        if (this.status !== PENDING) return
        this.status = FULFILLED
        this.value = value

        // 如果将状态修复为成功，调用成功的回调
        while (this.onFulfilled.length) {
            // Array.prototype.shift() 用于删除数组第一个元素，并返回
            this.onFulfilled.shift()(this.value)
        }
    }
    reject = (reason) => {
        if (this.status !== PENDING) return
        this.status = REJECTED
        this.reason = reason
        // 如果将状态修复为失败，调用失败的回调
        while (this.onRejected.length) {
            // Array.prototype.shift() 用于删除数组第一个元素，并返回
            this.onRejected.shift()(this.reason)
        }
    }
    then (onFulfilled, onRejected) {
        if (this.status === FULFILLED) {
            onFulfilled(this.value)
        } else if (this.status === REJECTED) {
            onRejected(this.reason)
        } else {
            // 表示既不是成功，也不是失败。这个时候保存传递进来的两个回调
            this.onFulfilled.push(onFulfilled)
            this.onRejected.push(onRejected)
        }
    }
}
module.exports = MyPromise

这里我们通过数组的shift()方法，该方法删除数组的第一个元素，并返回，返回的这个值正好是一个回调函数，然后调用该函数即可实现该功能。

实现then的链式调用

想要实现then的链式调用，主要解决两个问题：

返回的是一个新的MyPormise实例。
then的返回值作为下一次的链式调用的参数。

这里分为两种情况：

直接返回一个值，可以直接作为值使用
返回一个新的MyPormise实例，此时就需要判断其状态

实现代码如下：

// MyPromise.js
/* 省略的代码同上 */
class MyPromise {
    /* 省略的代码同上 */

    // then方法的实现
    then (onFulfilled, onRejected) {
        // then 方法返回一个MyPromise实例
        return new MyPromise((resolve, reject) => {
            // 判断当前状态,根据状态调用指定回调
            if (this.status === FULFILLED) {
                // 将成功的值作为参数返回
                // 保存执行回调函数的结果
                const result = onFulfilled(this.value)

                // 如果返回的是一个普通的值，直接调用resolve
                // 如果是一个MyPromise实例，根据返回的解决来决定是调用resolve，还是reject
                resolvePromise(result, resolve, reject)
            } else if (this.status === REJECTED) {
                // 将失败的原因作为参数返回
                onRejected(this.reason)
            } else {
                // 表示既不是成功，也不是失败。这个时候保存传递进来的两个回调
                this.onFulfilled.push(onFulfilled)
                this.onRejected.push(onRejected)
            }
        })
    }
}
function resolvePromise (result, resolve, reject) {
    // 判断传递的result是不是MyPromise的实例对象
    if (result instanceof MyPromise) {
        // 说明是MyPromise的实例对象
        // 调用.then方法，然后在回调函数中获取到具体的值，然后调用具体的回调
        // result.then(value => resolve(value), reason => reject(reason))
        // 简写
        result.then(resolve, reject)
    } else {
        resolve(result)
    }
}
module.exports = MyPromise

then方法链式调用识别Promise对象自返回

在Promise中，如果then方法返回的是自己的promise对象，则会发生promise的嵌套，这个时候程序会报错，

测试代码如下：

var promise = new Promise((resolve, reject) => {
  resolve(100)
})
var p1 = promise.then(value => {
  console.log(value)
  return p1
})
// 100
// Uncaught (in promise) TypeError: Chaining cycle detected for promise #<Promise>

想要解决这个问题其实我们只需要在then方法返回的MyPromise实例对象与then中回调函数返回的值进行比对，如果相同的返回一个reject的MyPromise实例对象，并创建一个TypeError类型的Error。

实现代码如下：

// MyPromise.js
    /* 省略的代码同上 */
    then (onFulfilled, onRejected) {
        // then 方法返回一个MyPromise实例
        const promise = new MyPromise((resolve, reject) => {
            // 判断当前状态,根据状态调用指定回调
            if (this.status === FULFILLED) {
                // 这里并不需要延迟执行，而是通过setTimeout将其变成异步函数
                // 如果不变成异步的话是在函数内获取不到promise的
                setTimeout(() => {
                    // 将成功的值作为参数返回
                    // 保存执行回调函数的结果
                    const result = onFulfilled(this.value)

                    // 如果返回的是一个普通的值，直接调用resolve
                    // 如果是一个MyPromise实例，根据返回的解决来决定是调用resolve，还是reject
                    resolvePromise(promise, result, resolve, reject)
                }, 0)
            } else if (this.status === REJECTED) {
                // 将失败的原因作为参数返回
                onRejected(this.reason)
            } else {
                // 表示既不是成功，也不是失败。这个时候保存传递进来的两个回调
                this.onFulfilled.push(onFulfilled)
                this.onRejected.push(onRejected)
            }
        })
        return promise
    }
}
function resolvePromise (promise, result, resolve, reject) {
    // 这里修改一下该函数，如果return的Promise实例对象，也就是传入的promise===result的话，说明在promise中return的是当前promise对象。
    if (promise === result) {
        // 这里调用reject，并抛出一个Error
        // return 是必须的，阻止程序向下执行
        return reject(new TypeError('Chaining cycle detected for promise #<Promise>'))
    }
    // 判断传递的result是不是MyPromise的实例对象
    if (result instanceof MyPromise) {
        // 说明是MyPromise的实例对象
        // 调用.then方法，然后在回调函数中获取到具体的值，然后调用具体的回调
        // result.then(value => resolve(value), reason => reject(reason))
        // 简写
        result.then(resolve, reject)
    } else {
        resolve(result)
    }
}
module.exports = MyPromise

这里then方法中的setTimeout的作用并不是延迟执行，而是为了调用resolvePromise函数时，保证创建的promise存在。

捕获错误及 then 链式调用其他状态代码补充

到目前为止我们现实的Promise并没有对异常做任何处理，为了保证代码的健壮性，我们需要对异常做一些处理。

捕获执行器错误

现在我们需要对执行器进行异常捕获，如果发生异常，就将我们的状态修改为rejected。

捕获执行器的错误也比较简单，只需要在构造函数中加入try...catch语句就可以，

实现代码如下：

    constructor(executor) {
        try {
            // 在调用executor需要传递两个回调函数，分别是resolve和reject
            executor(this.resolve, this.reject)
        } catch (e) {
            // 发生异常调用reject
            this.reject(e)
        }
    }

测试代码如下：

const MyPromise = require('./myPromise')
let promise = new MyPromise((resolve, reject) => {
    throw new Error('执行器错误')
})

promise.then(value => {
    console.log(value);
}, error => {
    console.log(error.message);
})
/* 输出
    执行器错误
*/

捕获then中的报错

现在我们需要对then中的异常捕获到，并在下一次链式调用中传递到then的第二个函数中，实现的方式也是通过try...catch语句，

示例代码如下：

// then方法的实现
then (onFulfilled, onRejected) {
    // then 方法返回一个MyPromise实例
    const promise = new MyPromise((resolve, reject) => {
        // 判断当前状态,根据状态调用指定回调
        if (this.status === FULFILLED) {
            // 这里并不需要延迟执行，而是通过setTimeout将其变成异步函数
            // 如果不变成异步的话是在函数内获取不到promise的
            setTimeout(() => {
                try {
                    // 将成功的值作为参数返回
                    // 保存执行回调函数的结果
                    const result = onFulfilled(this.value)

                    // 如果返回的是一个普通的值，直接调用resolve
                    // 如果是一个MyPromise实例，根据返回的解决来决定是调用resolve，还是reject
                    resolvePromise(promise, result, resolve, reject)
                } catch (error) {
                    reject(error)
                }
            }, 0)
        } else if (this.status === REJECTED) {
            // 将失败的原因作为参数返回
            onRejected(this.reason)
        } else {
            // 表示既不是成功，也不是失败。这个时候保存传递进来的两个回调
            this.onFulfilled.push(onFulfilled)
            this.onRejected.push(onRejected)
        }
    })
    return promise
}

测试代码如下：

const MyPromise = require('./myPromise')
let promise = new MyPromise((resolve, reject) => {
    resolve('成功')
})
// 第一个then方法中的错误要在第二个then方法中捕获到
promise.then(value => {
    console.log('resolve', value)
    throw new Error('then的执行过程中遇到异常')
}).then(null, reason => {
    console.log(reason.message)
})

/* 输出
    resolve 成功
    then的执行过程中遇到异常
*/

错误与异步状态的链式调用

现在只对成功状态的then进行的链式调用以及错误处理，错误与异步状态未进行处理，其实处理起来也是一样的，

示例代码如下：

    // then方法的实现
    then (onFulfilled, onRejected) {
        // then 方法返回一个MyPromise实例
        const promise = new MyPromise((resolve, reject) => {
            // 判断当前状态,根据状态调用指定回调
            if (this.status === FULFILLED) {
                // 这里并不需要延迟执行，而是通过setTimeout将其变成异步函数
                // 如果不变成异步的话是在函数内获取不到promise的
                setTimeout(() => {
                    try {
                        // 将成功的值作为参数返回
                        // 保存执行回调函数的结果
                        const result = onFulfilled(this.value)

                        // 如果返回的是一个普通的值，直接调用resolve
                        // 如果是一个MyPromise实例，根据返回的解决来决定是调用resolve，还是reject
                        resolvePromise(promise, result, resolve, reject)
                    } catch (error) {
                        reject(error)
                    }
                }, 0)
            } else if (this.status === REJECTED) {
                // 失败的处理同成功处理，只是调用的回调函数不同
                setTimeout(() => {
                    try {
                        const result = onRejected(this.reason)
                        resolvePromise(promise, result, resolve, reject)
                    } catch (error) {
                        reject(error)
                    }
                }, 0)
            } else {
                this.onFulfilled.push((value) => {
                    setTimeout(() => {
                        try {
                            const result = onFulfilled(value)
                            resolvePromise(promise, result, resolve, reject)
                        } catch (error) {
                            reject(error)
                        }
                    }, 0)
                })
                this.onRejected.push((reason) => {
                    setTimeout(() => {
                        try {
                            const result = onRejected(reason)
                            resolvePromise(promise, result, resolve, reject)
                        } catch (error) {
                            reject(error)
                        }
                    }, 0)
                })
            }
        })
        return promise
    }

测试代码如下：

const MyPromise = require('./myPromise')
let promise = new MyPromise((resolve, reject) => {
    setTimeout(resolve, 2000, '成功')
})
// 第一个then方法中的错误要在第二个then方法中捕获到
promise.then(value => {
    console.log('resolve', value)
    throw new Error('then的执行过程中遇到异常')
}).then(null, reason => {
    console.log(reason.message)
})
/* 输出
    resolve 成功
    then的执行过程中遇到异常
*/

将then方法的参数变成可选参数

Promise中的then方法其实是两个可以可选参数，如果我们不传递任何参数的话，里面的结果是向下传递的，直到捕获为止，

例如下面这段代码：

new Promise((resolve, reject) => {
    resolve(100)
})
    .then()
    .then()
    .then()
    .then(value => console.log(value))
// 最后一个then输入100

这段代码可以理解为：

new Promise((resolve, reject) => {
    resolve(100)
})
    .then(value => value)
    .then(value => value)
    .then(value => value)
    .then(value => console.log(value))

所以说我们只需要在没有传递回调函数时，赋值一个默认的回调函数即可。

实现代码如下：

// then方法的实现
then (onFulfilled, onRejected) {
    // 如果传递函数，就是用传递的函数，否则指定一个默认值，用于参数传递
    onFulfilled = onFulfilled ? onFulfilled : value => value
    // 同理
    onRejected = onRejected ? onRejected : reason => { throw reason }
    // then 方法返回一个MyPromise实例
    const promise = new MyPromise((resolve, reject) => {
        // 判断当前状态,根据状态调用指定回调
        if (this.status === FULFILLED) {...
        } else if (this.status === REJECTED) {...
        } else {...
        }
    })
    return promise
}

Promise.all方法的实现

关于all()方法的使用，可以参数Promise.all()。简单的说Promise.all()会将多个Promise实例包装为一个Promise实例，且顺序与调用顺序一致，

示例代码如下：

function p1 () {
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            resolve('p1')
        }, 2000)
    })
}
function p2 () {
    return new Promise((resolve, reject) => {
        setTimeout(() => {
            resolve('p2')
        }, 0)
    })
}
Promise.all(['a', 'b', p1(), p2(), 'c']).then(result => {
    console.log(result)
    // ["a", "b", "p1", "p2", "c"]
})

在这段代码中，我们的p1的执行是延迟了2s的，这里如果不使用Promise.all()的话最终顺序是与我们调用不同的。

现在我们来分析一下all()的实现思路：

all()方法可以通过类直接调用，所以是一个静态方法
all()方法接收一个数组，数组中的值可以是一个普通值，也可以是一个MyPromise的实例对象
return一个新的MyPromise实例对象
遍历数组中的每一个值，判断值得类型，如果是一个普通值得话直接将值存入一个数组；如果是一个MyPromise的实例对象的话，会调用then方法，然后根据执行后的状态，如果失败的话调用新的MyPromise实例对象中的rejecte，如果是成功话将这个值存入一个数组
存入数组时计数，如果存入的数量达到传入的数组长度，说明调用完毕，执行resolve并将最终的结果数组作为参数返回。

实现代码：

/** 
 * @description: 将多个Promise实例合并为一个Promise实例
 * @param {*} array Promise或者普通值
 * @returns {Promise}
 */
static all (array) {
    // 用于存放最终结果的数组
    let result = []
    // 用于计算当前已经执行完的实例的数量
    let count = 0
    // 最后返回的是一个Promise实例
    return new MyPromise((resolve, reject) => {
        /** 
         * @description: 将执行完毕的值加入结果数组，并根据实际情况决定是否调用resolve
         * @param {*} result 存放结果的数组
         * @param {*} index 要加入的索引
         * @param {*} value 要加入数组的值
         * @param {*} resolve Promise中的resolve
         */
        function addResult (result, index, value, resolve) {
            // 根据索引值，将结果堆入数组中
            result[index] = value
            // 执行完毕一个 count 1，如果当前值等于总长度的话说明已经执行结束了，可以直接调用resolve，说明已经成功执行完毕了
            if (  count === array.length) {
                // 将执行结果返回
                resolve(result)
            }
        }
        // 遍历穿入的数组，每个都执行then方法，获取到最终的结果
        array.forEach((p, index) => {
            // 判断p是不是MyPromise的实例，如果是的话调用then方法，不是直接将值加入数组中
            if (p instanceof MyPromise) {
                p.then(
                    // 成功时将结果直接加入数组中
                    value => {
                        addResult(result, index, value, resolve)
                    },
                    // 如果失败直接返回失败原因
                    reason => {
                        reject(reason)
                    }
                )
            }
            else {
                addResult(result, index, p, resolve)
            }
        })
    })
}

Promise.resolve方法的实现

关于Promise.resolve()方法的用法可以参考Promise.resolve()与Promise.reject()。

我们实现的思路主要如下：

该方法是一个静态方法
该方法接受的如果是一个值就将该值包装为一个MyPromise的实例对象返回，如果是一个MyPromise的实例对象，调用then方法返回。

实现代码如下：

static resolve (value) {
    // 如果是MyPromise的实例，就直接返回这个实例
    if (value instanceof MyPromise) return value
    // 如果不是的话创建一个MyPromise实例，并返回传递的值
    return new MyPromise((resolve) => {
        resolve(value)
    })
}

finally方法的实现

关于finally方法可参考finally()，实现该方法的实现代码如下：

finally (callback) {
    // 如何拿到当前的promise的状态，使用then方法，而且不管怎样都返回callback
    // 而且then方法就是返回一个promise对象，那么我们直接返回then方法调用之后的结果即可
    // 我们需要在回调之后拿到成功的回调，所以需要把value也return
    // 失败的回调也抛出原因
    // 如果callback是一个异步的promise对象，我们还需要等待其执行完毕，所以需要用到静态方法resolve
    return this.then(value => {
        // 把callback调用之后返回的promise传递过去，并且执行promise，且在成功之后返回value
        return MyPromise.resolve(callback()).then(() => value)
    }, reason => {
        // 失败之后调用的then方法，然后把失败的原因返回出去。
        return MyPromise.resolve(callback()).then(() => { throw reason })
    })
}

测试：

function p1 () {
    return new MyPromise((resolve, reject) => {
        setTimeout(() => {
            resolve('p1')
        }, 2000)
    })
}
function p2 () {
    return new MyPromise((resolve, reject) => {
        reject('p2 reject')
    })
}
p2().finally(
    () => {
        console.log('finally p2')
        return p1()
    }
).then(
    value => {
        console.log(value)
    }, reason => {
        console.log(reason)
    }
)
// finally p2
// 两秒之后执行p2 reject

catch方法的实现

关于catch方法可以参考catch()，实现该方法其实非常简单，只需要在内部调用then方法，不传递第一个回调函数即可，

实现代码如下：

catch (callback) {
    return this.then(null, failCallback)
}

测试如下：

function p () {
    return new MyPromise((resolve, reject) => {
        reject(new Error('reject'))
    })
}
p()
    .then(value => {
        console.log(value)
    })
    .catch(reason => console.log(reason))

完整代码

// MyPromise.js
// 定义所有状态的常量
const PENDING = 'pending'
const FULFILLED = 'fulfilled'
const REJECTED = 'rejected'
// Promise实质上就是一个类，首先创建一个Promise的类
class MyPromise {
    // 实例化Promise时需要一个回调函数，该回调函数立即执行
    constructor(executor) {
        try {
            // 在调用executor需要传递两个回调函数，分别是resolve和reject
            executor(this.resolve, this.reject)
        } catch (e) {
            // 发生异常调用reject
            this.reject(e)
        }
    }
    // Promise 的状态
    status = PENDING
    // 记录成功与失败的值
    value = undefined
    reason = undefined
    // 存储成功与失败的处理逻辑
    onFulfilled = []
    onRejected = []

    resolve = (value) => {// 这里使用箭头函数是为了使其内部的this指向为该实例化后的对象
        // 形参value表示，调用resolve时传递的参数
        // 如果当前状态不是pending，就直接跳出该逻辑
        if (this.status !== PENDING) return
        // 将状态修改为成功
        this.status = FULFILLED
        // 将传入的值进行保存
        this.value = value
        // 如果将状态修复为成功，调用成功的回调
        // this.onFulfilled && this.onFulfilled(this.value)
        while (this.onFulfilled.length) {
            // Array.prototype.shift() 用于删除数组第一个元素，并返回
            this.onFulfilled.shift()(this.value)
        }
    }
    reject = (reason) => {// 这里使用箭头函数是为了使其内部的this指向为该实例化后的对象
        // 形参reason表示，调用reject时传递的失败的原因
        // 如果当前状态不是pending，就直接跳出该逻辑
        if (this.status !== PENDING) return

        // 将状态修改为失败
        this.status = REJECTED

        // 保存失败的原因
        this.reason = reason

        // 如果将状态修复为失败，调用失败的回调
        // this.onRejected && this.onRejected(this.reason)
        while (this.onRejected.length) {
            // Array.prototype.shift() 用于删除数组第一个元素，并返回
            this.onRejected.shift()(this.reason)
        }
    }
    // then方法的实现
    then (onFulfilled, onRejected) {
        // 如果传递函数，就是用传递的函数，否则指定一个默认值，用于参数传递
        onFulfilled = onFulfilled ? onFulfilled : value => value
        // 同理
        onRejected = onRejected ? onRejected : reason => { throw reason }
        // then 方法返回一个MyPromise实例
        const promise = new MyPromise((resolve, reject) => {
            // 判断当前状态,根据状态调用指定回调
            if (this.status === FULFILLED) {
                // 这里并不需要延迟执行，而是通过setTimeout将其变成异步函数
                // 如果不变成异步的话是在函数内获取不到promise的
                setTimeout(() => {
                    try {
                        // 将成功的值作为参数返回
                        // 保存执行回调函数的结果
                        const result = onFulfilled(this.value)

                        // 如果返回的是一个普通的值，直接调用resolve
                        // 如果是一个MyPromise实例，根据返回的解决来决定是调用resolve，还是reject
                        resolvePromise(promise, result, resolve, reject)
                    } catch (error) {
                        reject(error)
                    }
                }, 0)
            } else if (this.status === REJECTED) {
                // 失败的处理同成功处理，只是调用的回调函数不同
                setTimeout(() => {
                    try {
                        const result = onRejected(this.reason)
                        resolvePromise(promise, result, resolve, reject)
                    } catch (error) {
                        reject(error)
                    }
                }, 0)
            } else {
                // 表示既不是成功，也不是失败。这个时候保存传递进来的两个回调
                // this.onFulfilled.push(onFulfilled)
                // this.onRejected.push(onRejected)
                this.onFulfilled.push((value) => {
                    setTimeout(() => {
                        try {
                            const result = onFulfilled(value)
                            resolvePromise(promise, result, resolve, reject)
                        } catch (error) {
                            reject(error)
                        }
                    }, 0)
                })
                this.onRejected.push((reason) => {
                    setTimeout(() => {
                        try {
                            const result = onRejected(reason)
                            resolvePromise(promise, result, resolve, reject)
                        } catch (error) {
                            reject(error)
                        }
                    }, 0)
                })
            }
        })
        return promise
    }
    catch (callback) {
        return this.then(null, callback)
    }
    finally (callback) {
        // 如何拿到当前的promise的状态，使用then方法，而且不管怎样都返回callback
        // 而且then方法就是返回一个promise对象，那么我们直接返回then方法调用之后的结果即可
        // 我们需要在回调之后拿到成功的回调，所以需要把value也return
        // 失败的回调也抛出原因
        // 如果callback是一个异步的promise对象，我们还需要等待其执行完毕，所以需要用到静态方法resolve
        return this.then(value => {
            // 把callback调用之后返回的promise传递过去，并且执行promise，且在成功之后返回value
            return MyPromise.resolve(callback()).then(() => value)
        }, reason => {
            // 失败之后调用的then方法，然后把失败的原因返回出去。
            return MyPromise.resolve(callback()).then(() => { throw reason })
        })
    }
    /** 
     * @description: 将多个Promise实例合并为一个Promise实例
     * @param {*} array Promise或者普通值
     * @returns {Promise}
     */
    static all (array) {
        // 用于存放最终结果的数组
        let result = []
        // 用于计算当前已经执行完的实例的数量
        let count = 0
        // 最后返回的是一个Promise实例
        return new MyPromise((resolve, reject) => {
            /** 
             * @description: 将执行完毕的值加入结果数组，并根据实际情况决定是否调用resolve
             * @param {*} result 存放结果的数组
             * @param {*} index 要加入的索引
             * @param {*} value 要加入数组的值
             * @param {*} resolve Promise中的resolve
             */
            function addResult (result, index, value, resolve) {
                // 根据索引值，将结果堆入数组中
                result[index] = value
                // 执行完毕一个 count 1，如果当前值等于总长度的话说明已经执行结束了，可以直接调用resolve，说明已经成功执行完毕了
                if (  count === array.length) {
                    // 将执行结果返回
                    resolve(result)
                }
            }
            // 遍历穿入的数组，每个都执行then方法，获取到最终的结果
            array.forEach((p, index) => {
                // 判断p是不是MyPromise的实例，如果是的话调用then方法，不是直接将值加入数组中
                if (p instanceof MyPromise) {
                    p.then(
                        // 成功时将结果直接加入数组中
                        value => {
                            addResult(result, index, value, resolve)
                        },
                        // 如果失败直接返回失败原因
                        reason => {
                            reject(reason)
                        }
                    )
                }
                else {
                    addResult(result, index, p, resolve)
                }
            })
        })
    }
    static resolve (value) {
        // 如果是MyPromise的实例，就直接返回这个实例
        if (value instanceof MyPromise) return value
        // 如果不是的话创建一个MyPromise实例，并返回传递的值
        return new MyPromise((resolve) => {
            resolve(value)
        })
    }

}
function resolvePromise (promise, result, resolve, reject) {
    // 这里修改一下该函数，如果return的Promise实例对象，也就是传入的promise===result的话，说明在promise中return的是当前promise对象。
    if (promise === result) {
        // 这里调用reject，并抛出一个Error
        // return 是必须的，阻止程序向下执行
        return reject(new TypeError('Chaining cycle detected for promise #<Promise>'))
    }
    // 判断传递的result是不是MyPromise的实例对象
    if (result instanceof MyPromise) {
        // 说明是MyPromise的实例对象
        // 调用.then方法，然后在回调函数中获取到具体的值，然后调用具体的回调
        // result.then(value => resolve(value), reason => reject(reason))
        // 简写
        result.then(resolve, reject)
    } else {
        resolve(result)
    }
}
module.exports = MyPromise

到此这篇关于万字详解JavaScript手写一个Promise的文章就介绍到这了,更多相关JS手写Promise内容请搜索Devmax以前的文章或继续浏览下面的相关文章希望大家以后多多支持Devmax！

万字详解JavaScript手写一个Promise的更多相关文章

基于JavaScript编写一个图片转PDF转换器

本文为大家介绍了一个简单的 JavaScript 项目，可以将图片转换为 PDF 文件。你可以从本地选择任何一张图片，只需点击一下即可将其转换为 PDF 文件，感兴趣的可以动手尝试一下
HTML5数字输入仅接受整数的实现代码

这篇文章主要介绍了HTML5数字输入仅接受整数的实现代码,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
amaze ui 的使用详细教程

这篇文章主要介绍了amaze ui 的使用详细教程,本文通过多种方法给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
html5简介_动力节点Java学院整理

这篇文章主要介绍了html5简介,用于指定构建网页的元素，这些元素中的大多数都用于描述网页内容，有兴趣的可以了解一下
ios 8 Homescreen webapp,关闭和打开iPad停止javascript

我有一个适用于iPad的全屏HTML5网络应用程序,并且刚刚安装了IOS8来试用它,它一切正常,直到你关闭并重新启动iPad.一旦web应用程序重新启动javascript就会停止并加载新页面不会重新启动它.在iPad上的Safari中打开同一页面时,关闭和打开iPad会继续按预期工作.其他人注意到了这个或想出了一个解决方案吗？解决方法这似乎是我在iOS8.1.1更新中解决的.
iOS 6 javascript与object.defineProperty的间歇性问题

当访问使用较新的Object.defineProperty语法定义属性的对象的属性时,有没有其他人注意到新iOS6javascript引擎中的间歇性错误/问题？https://developer.mozilla.org/en-US/docs/JavaScript/Reference/Global_Objects/Object/defineProperty我正在看到javascript失败的情况,说
ios – 如何使用JSExport导出内部类的方法

解决方法似乎没有办法将内部类函数导出到javascript.我将内部类移出并创建了独立的类,它起作用了.
静音iOS推送通知与React Native应用程序在后台

我有一个ReactNative应用程序,我试图获得一个发送到JavaScript处理程序的静默iOS推送通知.我看到的行为是AppDelegate中的didReceiveRemoteNotification函数被调用,但是我的JavaScript中的处理程序不会被调用,除非应用程序在前台,或者最近才被关闭.我很困惑的事情显然是应用程序正在被唤醒,并且它的didReceiveRemoteNotifi
ios – 内存泄漏与UIWebView和Javascript

清楚地包含一个Javascript文件到我的HTML是使UIWebView泄漏内存.当我重复使用相同的UIWebView对象时,或者每当我有内容实例化一个新的漏洞时,会出现泄漏的事实,导致我认为必须有一些JavaScript文件被loadHTMLString处理,导致泄漏.有人知道如何解决这个问题吗？
iOS应用程序的UI自动化测试如何与乐器和Javascript

从WWDC2010视频会议中了解iOS应用程序的自动化UI测试,但没有实践.从代码项目project,我们可以有一个例子.这个问题在这里听到有涉及这个的人.任何限制？解决方法我建议从AlexWollmer开始使用thisblogpost.他创建了一个非常有用的JavaScript库：tuneup_jswithtest()函数,它允许测试分离和有用的帮助者以及为自动化仪器编写测试的断言.

随机推荐

js中‘!.’是什么意思
Vue如何指定不编译的文件夹和favicon.ico

这篇文章主要介绍了Vue如何指定不编译的文件夹和favicon.ico，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
基于JavaScript编写一个图片转PDF转换器

本文为大家介绍了一个简单的 JavaScript 项目，可以将图片转换为 PDF 文件。你可以从本地选择任何一张图片，只需点击一下即可将其转换为 PDF 文件，感兴趣的可以动手尝试一下
jquery点赞功能实现代码点个赞吧!

点赞功能很多地方都会出现，如何实现爱心点赞功能，这篇文章主要为大家详细介绍了jquery点赞功能实现代码，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
AngularJs上传前预览图片的实例代码

使用AngularJs进行开发，在项目中，经常会遇到上传图片后，需在一旁预览图片内容，怎么实现这样的功能呢？今天小编给大家分享AugularJs上传前预览图片的实现代码，需要的朋友参考下吧
JavaScript面向对象编程入门教程

这篇文章主要介绍了JavaScript面向对象编程的相关概念，例如类、对象、属性、方法等面向对象的术语，并以实例讲解各种术语的使用，非常好的一篇面向对象入门教程,其它语言也可以参考哦
jQuery中的通配符选择器使用总结

通配符在控制input标签时相当好用,这里简单进行了jQuery中的通配符选择器使用总结,需要的朋友可以参考下
javascript 动态调整图片尺寸实现代码

在自己的网站上更新文章时一个比较常见的问题是：文章插图太宽，使整个网页都变形了。如果对每个插图都先进行缩放再插入的话，太麻烦了。
jquery ajaxfileupload异步上传插件

这篇文章主要为大家详细介绍了jquery ajaxfileupload异步上传插件，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
React学习之受控组件与数据共享实例分析

这篇文章主要介绍了React学习之受控组件与数据共享,结合实例形式分析了React受控组件与组件间数据共享相关原理与使用技巧,需要的朋友可以参考下