ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

es6:class实现一个promise

2021-05-14 20:52:39  阅读:188  来源: 互联网

标签:STATUS es6 resolve res promise reject class


参考:

1.https://www.jianshu.com/p/f841eb3c1006

2.https://blog.csdn.net/qq_31967985/article/details/109902310

阶段一:只支持链式调用不支持其他api

// 定义promise中的三种状态
const STATUS_PENDING = "pending";
const STATUS_FULFILLED = "fulfilled";
const STATUS_REJECTED = "rejected";

// 定义promise的类
class myPromise {
  //class的构造函数,接受新建实例时的参数:executor在promise中是一个函数
  constructor(executor) {
        //初始化该class中的初始状态
        this.status = STATUS_PENDING;
        //定义class中成功(res)和失败(err)时的变量值
        this.res = "";
        this.err = "";

        //promis异步中最重要的异步,定义成功和错误函数存储的数组,存放异步时还没有执行的操作
        this.onResCallbacks = [];
        this.onErrCallbacks = [];

        //按照promise中的逻辑,在调用时就立即执行了,所以在手写的myPromise创建构造函数constructor时就执行executor
        try {
            //执行参入的函数,并将上述定义的resolve和reject作为参数传入
            executor(this.resolve.bind(this), this.reject.bind(this)) // 绑定当前实例
        } catch (err) {
            //报错时调用失败的状态函数
            reject(err);
        }
    }
    resolve(res){
        // 首先判断该class中的状态,只有状态为pending时才能转化class转态为fulfilled或者rejected
        this.status === STATUS_PENDING && (
            //修改class的转态为fulfilled,也就表示不会转进行其他转态的转化了
            this.status = STATUS_FULFILLED,
            //将成功(resolve)状态下的值赋给class的成功返回res
            this.res = res,
            //此时状态由pending转为fulfilled,执行之前在then中存放的需要执行的异步操作,promise的then中参数res接受结果
            this.onResCallbacks.forEach((fn)=>fn())
        )
        return this;
    }
    //定义该构造函数constructor定义域中的变量reject
    reject(err){
        // 首先判断该class中的状态,只有状态为pending时才能转化class转态为fulfilled或者rejected
        this.status === STATUS_PENDING && (
            //修改class的转态为rejected,也就表示不会转进行其他转态的转化了
            this.status = STATUS_REJECTED,
            this.err = err,
            //此时状态由pending转为rejected,执行之前在catch中存放的需要执行的异步操作,promise的catch中参数err接受结果
            this.onErrCallbacks.forEach((fn)=>fn())
        )
        return this;
    }
    resolvePromise(x,resolve, reject) {
        // 如果返回的是myPromise实例
        if (x instanceof myPromise) {
            x.then(
                data => {
                    resolve(data)
                },
                error => {
                    reject(error)
                }
            )
        } else {
            // 普通值:直接执行then返回的新promise方法的resolve,后一个then属于这个实例的,订阅队列也是属于这个实例的
            resolve(x)
        }
    }
    //在class中定义promise的成功状态接收函数then,按照promise逻辑,then中传入的一般都是一个函数
    then(success, fail){
        // 链式调用 后一个then调用前一个then返回的promise实例
        let p = new myPromise((resolve, reject) => {
            if (this.status === STATUS_PENDING) {
                // promise实例还在pending状态调用了then方法,增加订阅者
                if (success && typeof success === 'function') {
                    this.onResCallbacks.push(() => {
                        try {
                            // 用户调用then方法,callback函数,两种情况
                            // 1 非promise对象: return 什么就作为参数传递给下个then什么
                            // 2 promise对象:择要等用户的promise的有结果才执行下一个函数
                            let x = success(this.res)
                            // 统一封装到一个函数中处理
                            this.resolvePromise(x, resolve, reject)
                        } catch (e) {
                            reject(e)
                        }
                    })
                }
                if (fail && typeof fail === 'function') {
                    this.onErrCallbacks.push(() => {
                        try {
                            let x  = fail(this.err)
                            this.resolvePromise(x, resolve, reject)
                        } catch (e) {
                            reject(e)
                        }
                    })
                }
            } else if (this.status === STATUS_FULFILLED) {
                try {
                    let x  = success(this.res)
                    this.resolvePromise(x, resolve, reject)
                } catch (e) {
                    reject(e)
                }
            } else if(this._status === STATUS_REJECTED) {
                try {
                    let x  = fail(this.err)
                    this.resolvePromise(x, resolve, reject)
                } catch (e) {
                    reject(e)
                }
            }
        })
        return p
    }

    //在class中定义promise的失败状态接收函数catch,按照promise逻辑,catch中传入的一般都是一个函数
    catch(onErr = () => {}) {
        //如果是异步的,此时在constructor中status的状态还没变成rejected,所以会跳过onErr调用,没有返回
        if (this.status === STATUS_REJECTED) {
            onErr(this.err);
        }
        //但是我们将此时的异步放入数组存放
        if (this.status === STATUS_PENDING) {
            this.onErrCallbacks.push(() => onErr(this.err));
        }
        //这步操作保证了then和catch能够在同级一起"."调起,当catch上述操作完后,返回class实例,便可以接在后面继续调用then
        return this;
    }
}
let my = new myPromise(()=>{});
new myPromise(function (resolve, reject) {
    console.log(00000)
    setTimeout(() => {
        resolve(222);
        console.log(111)
    }, 1000);
}).then(function (res) {
    console.log('2 then')
        console.log(res)
        
        return my.resolve("hello world3333")
}).then(function (res) {
    console.log(res);
    console.log('last then')
});

 

标签:STATUS,es6,resolve,res,promise,reject,class
来源: https://blog.51cto.com/u_15201483/2776351

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有