手写实现Promise功能

简单粗暴,全部代码如下:

class Promise{

    constructor(executor){

      this.state = 'pending';

      this.value = undefined;

      this.reason = undefined;

      this.onResolvedCallbacks = [];

      this.onRejectedCallbacks = [];

      let resolve = value => {

        if (this.state === 'pending') {

          this.state = 'fulfilled';

          this.value = value;

          this.onResolvedCallbacks.forEach(fn=>fn());

        }

      };

      let reject = reason => {

        if (this.state === 'pending') {

          this.state = 'rejected';

          this.reason = reason;

          this.onRejectedCallbacks.forEach(fn=>fn());

        }

      };

      try{

        executor(resolve, reject);

      } catch (err) {

        reject(err);

      }

    }

    then(onFulfilled,onRejected) {

      onFulfilled = typeof onFulfilled === 'function' ? onFulfilled : value => value;

      onRejected = typeof onRejected === 'function' ? onRejected : err => { throw err };

      let promise2 = new Promise((resolve, reject) => {

        if (this.state === 'fulfilled') {

          setTimeout(() => {

            try {

              let x = onFulfilled(this.value);

              resolvePromise(promise2, x, resolve, reject);

            } catch (e) {

              reject(e);

            }

          }, 0);

        };

        if (this.state === 'rejected') {

          setTimeout(() => {

            try {

              let x = onRejected(this.reason);

              resolvePromise(promise2, x, resolve, reject);

            } catch (e) {

              reject(e);

            }

          }, 0);

        };

        if (this.state === 'pending') {

          this.onResolvedCallbacks.push(() => {

            setTimeout(() => {

              try {

                let x = onFulfilled(this.value);

                resolvePromise(promise2, x, resolve, reject);

              } catch (e) {

                reject(e);

              }

            }, 0);

          });

          this.onRejectedCallbacks.push(() => {

            setTimeout(() => {

              try {

                let x = onRejected(this.reason);

                resolvePromise(promise2, x, resolve, reject);

              } catch (e) {

                reject(e);

              }

            }, 0)

          });

        };

      });

      return promise2;

    }

    catch(fn){

      return this.then(null,fn);

    }

  }

  function resolvePromise(promise2, x, resolve, reject){

    if(x === promise2){

      return reject(new TypeError('Chaining cycle detected for promise'));

    }

    let called;

    if (x != null && (typeof x === 'object' || typeof x === 'function')) {

      try {

        let then = x.then;

        if (typeof then === 'function') {

          then.call(x, y => {

            if(called)return;

            called = true;

            resolvePromise(promise2, y, resolve, reject);

          }, err => {

            if(called)return;

            called = true;

            reject(err);

          })

        } else {

          resolve(x);

        }

      } catch (e) {

        if(called)return;

        called = true;

        reject(e);

      }

    } else {

      resolve(x);

    }

  }

  //resolve方法

  Promise.resolve = function(val){

    return new Promise((resolve,reject)=>{

      resolve(val)

    });

  }

  //reject方法

  Promise.reject = function(val){

    return new Promise((resolve,reject)=>{

      reject(val)

    });

  }

  //race方法

  Promise.race = function(promises){

    return new Promise((resolve,reject)=>{

      for(let i=0;i<promises.length;i++){

        promises[i].then(resolve,reject)

      };

    })

  }

  //all方法(获取所有的promise,都执行then,把结果放到数组,一起返回)

  Promise.all = function(promises){

    let arr = [];

    let i = 0;

    function processData(index,data){

      arr[index] = data;

      i++;

      if(i == promises.length){

        resolve(arr);

      };

    };

    return new Promise((resolve,reject)=>{

      for(let i=0;i<promises.length;i++){

        promises[i].then(data=>{

          processData(i,data);

        },reject);

      };

    });

  }

  let p = new Promise((resolve,reject)=>{

      resolve(100)

  })

  p.then((res)=>{

    console.log("success",res)

},(err)=>{

    console.log(err)

})

p.then((res)=>{

    console.log("success2",res)

},(err)=>{

    console.log(err)

})

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 前言 本文旨在简单讲解一下javascript中的Promise对象的概念,特性与简单的使用方法。并在文末会附上一...
    _暮雨清秋_阅读 2,248评论 0 3
  • 1.promise简介 1.1 Promise本意是承诺,在程序中的意思就是承诺我过一段时间后会给你一个结果...
    常青_1f93阅读 869评论 0 1
  • 一· 什么是Promise Promise是抽象异步处理对象以及对其进行各种操作的组件。 其实这样说起来还是比较抽...
    时光与少年已陈旧阅读 989评论 0 0
  • Promise 对象 Promise 的含义 Promise 是异步编程的一种解决方案,比传统的解决方案——回调函...
    neromous阅读 8,734评论 1 56
  • 本文适用的读者 本文写给有一定Promise使用经验的人,如果你还没有使用过Promise,这篇文章可能不适合你,...
    HZ充电大喵阅读 7,341评论 6 19