美文网首页
自己手动实现promise方法

自己手动实现promise方法

作者: Angrybird233 | 来源:发表于2024-03-17 14:07 被阅读0次
class myPromise {
  resolve;
  reject;
  // 构造函数 CustomPromise(executor):在构造函数中初始化 Promise 的状态为 pending,并接受一个执行器函数 executor,
  // 该函数包含两个参数 resolve 和 reject,用于改变 Promise 的状态和传递结果或错误。
  constructor(excuctor) {
    this.status = "pending";
    this.value = undefined;
    this.error = undefined;
    this.onResolveCallbacks = [];
    this.onRejectCallbacks = [];

    // resolve(value) 和 reject(error) 方法:分别用于将 Promise 状态改变为 fulfilled 和 rejected,并触发相应的回调函数。
    const resolve = value => {
      if (this.status === "pending") {
        this.status = "fulfilled";
        this.value = value;
        this.onResolveCallbacks.forEach(callback => callback(this.value))
      }
    }
    const reject = error => {
      if (this.status === "pending") {
        this.status = "rejected";
        this.error = error;
        this.onRejectCallbacks.forEach(callback => callback(this.error))
      }
    }
    try {
      excuctor(resolve, reject);
    } catch (error) {
      reject(error);
    }
  }

  // then(onFulfilled, onRejected) 方法:用于注册成功和失败的回调函数,并返回一个新的 Promise 对象。
  // 根据当前 Promise 的状态,分别处理 fulfilled 和 rejected 的情况,异步执行回调函数并根据返回值决定新 Promise 的状态和结果。
  then(onFulfilled, onRejected){
    return new myPromise((resolve, reject)=>{
      const handleCallback = (callback, value, resolve, reject)=> {
        try {
          const result = callback(value);
          if(result instanceof myPromise ){
            result.then(resolve, reject)
          }else{
            resolve(result)
          }
        } catch (error) {
          reject(error)
        }
      }

      if(this.status === 'fulfilled'){
        setTimeout(() => {
          handleCallback(onFulfilled, this.value, resolve, reject)
        }, 0);
      }
      if(this.status === 'rejected'){
        setTimeout(() => {
          handleCallback(onRejected, this.error, resolve, reject)
        }, 0);
      }
      if(this.status === 'pending'){
        this.onResolveCallbacks.push(() => {
          setTimeout(() => {
            handleCallback(onFulfilled, this.value, resolve, reject)
          }, 0);
        })
        this.onRejectCallbacks.push(() => {
          setTimeout(() => {
            handleCallback(onRejected, this.error, resolve, reject)
          }, 0);
        })
      }



    })
  }
  // catch(onRejected) 方法:用于注册失败的回调函数,实际上是调用 then(null, onRejected)。

  catch() {
    return this.then(null, onRejected)
  }

  // 静态方法 resolve(value) 和 reject(error):分别返回一个已经 resolved 或 rejected 的 Promise 对象。
  static resolve(value) {
    return new myPromise((resolve, reject)=> {
      resolve(value)
    })
  }
  static reject(error) {
    return new myPromise((resolve, reject) => {
      reject(error)
    })
  }

  // 静态方法 all(promises):接受一个 Promise 数组,并返回一个新的 Promise 对象,
  // 当所有 Promise 都成功时,返回一个包含所有结果的数组;当任意一个 Promise 失败时,直接返回失败的 Promise。
  static all(events) {
    return new myPromise((resolve, reject) => {
      const results = [];
      let completeIndex = 0;
      events.forEach((promise, index) => {
        promise.then(res => {
          results[index] = item;
          completeIndex++;
          if(completeIndex === results.length){
            resolve(results)
          }
        }).catch(reject)
      })

    })
  }

}

export default myPromise;

相关文章

网友评论

      本文标题:自己手动实现promise方法

      本文链接:https://www.haomeiwen.com/subject/mowozdtx.html