手写一个符合Promises/A+规范的Promise_js深度探索-js教程-PHP中文网

手写一个符合Promises/A+规范的Promise_js深度探索

狼影

发布： 2025-11-05 23:41:01

原创

867人浏览过

答案：手写符合Promises/A+规范的Promise需实现状态机、then链式调用与resolvePromise递归解析；包含pending/fulfilled/rejected三种状态，通过resolve/reject函数改变状态，then方法返回新Promise并注册回调，利用queueMicrotask确保异步执行，resolvePromise处理返回值为Promise或thenable的情况，防止循环引用，同时实现catch、finally、resolve、reject等辅助方法。

手写一个符合promises/a+规范的promise_js深度探索

要手写一个符合 Promises/A+ 规范的 Promise，关键在于理解其核心机制：状态机、异步执行、then 方法的链式调用与穿透，以及 onFulfilled 和 onRejected 的回调调度。下面从零实现一个精简但完全符合规范的 Promise 类。

Promise 核心状态与基本结构

Promise 有三种状态：pending（等待）、fulfilled（成功）、rejected（失败）。一旦状态变更，就不能再改变。

const PENDING = 'pending';
const FULFILLED = 'fulfilled';
const REJECTED = 'rejected';

function MyPromise(executor) {
  this.state = PENDING;
  this.value = undefined;
  this.reason = undefined;
  this.onFulfilledCallbacks = [];
  this.onRejectedCallbacks = [];

  const resolve = (value) => {
    if (this.state === PENDING) {
      this.state = FULFILLED;
      this.value = value;
      this.onFulfilledCallbacks.forEach(fn => fn());
    }
  };

  const reject = (reason) => {
    if (this.state === PENDING) {
      this.state = REJECTED;
      this.reason = reason;
      this.onRejectedCallbacks.forEach(fn => fn());
    }
  };

  try {
    executor(resolve, reject);
  } catch (error) {
    reject(error);
  }
}

登录后复制

实现 then 方法

then 方法是 Promise 的核心，必须返回一个新的 Promise，实现链式调用。它接收两个可选参数：onFulfilled 和 onRejected。

MyPromise.prototype.then = function(onFulfilled, onRejected) {
  // 处理透传，支持 .then().then(value => ...)
  onFulfilled = typeof onFulfilled === 'function' ? onFulfilled : value => value;
  onRejected = typeof onRejected === 'function' ? onRejected : reason => { throw reason; };

  const promise2 = new MyPromise((resolve, reject) => {
    if (this.state === FULFILLED) {
      queueMicrotask(() => {
        try {
          const x = onFulfilled(this.value);
          resolvePromise(promise2, x, resolve, reject);
        } catch (e) {
          reject(e);
        }
      });
    }

    if (this.state === REJECTED) {
      queueMicrotask(() => {
        try {
          const x = onRejected(this.reason);
          resolvePromise(promise2, x, resolve, reject);
        } catch (e) {
          reject(e);
        }
      });
    }

    if (this.state === PENDING) {
      this.onFulfilledCallbacks.push(() => {
        queueMicrotask(() => {
          try {
            const x = onFulfilled(this.value);
            resolvePromise(promise2, x, resolve, reject);
          } catch (e) {
            reject(e);
          }
        });
      });

      this.onRejectedCallbacks.push(() => {
        queueMicrotask(() => {
          try {
            const x = onRejected(this.reason);
            resolvePromise(promise2, x, resolve, reject);
          } catch (e) {
            reject(e);
          }
        });
      });
    }
  });

  return promise2;
};

登录后复制

处理 then 返回值：resolvePromise 函数

这个函数决定如何处理 onFulfilled/onRejected 的返回值 x。根据 Promises/A+ 规范，x 可能是普通值、Promise 或带有 then 方法的对象（即“thenable”）。

文赋Ai论文

专业/高质量智能论文AI生成器-在线快速生成论文初稿

查看详情

function resolvePromise(promise2, x, resolve, reject) {
  if (promise2 === x) {
    return reject(new TypeError('Chaining cycle detected for promise'));
  }

  let called = false;

  if ((typeof x === 'object' && x !== null) || typeof x === 'function') {
    let then;
    try {
      then = x.then;
      if (typeof then === 'function') {
        then.call(x, y => {
          if (called) return;
          called = true;
          resolvePromise(promise2, y, resolve, reject);
        }, r => {
          if (called) return;
          called = true;
          reject(r);
        });
      } else {
        resolve(x);
      }
    } catch (e) {
      if (called) return;
      called = true;
      reject(e);
    }
  } else {
    resolve(x);
  }
}

登录后复制

补充常用方法：catch、finally、resolve、reject

这些是基于 then 的语法糖，增强使用体验。

MyPromise.prototype.catch = function(onRejected) {
  return this.then(null, onRejected);
};

MyPromise.prototype.finally = function(callback) {
  return this.then(
    value => MyPromise.resolve(callback()).then(() => value),
    reason => MyPromise.resolve(callback()).then(() => { throw reason; })
  );
};

MyPromise.resolve = function(value) {
  if (value instanceof MyPromise) return value;
  return new MyPromise(resolve => resolve(value));
};

MyPromise.reject = function(reason) {
  return new MyPromise((_, reject) => reject(reason));
};

登录后复制

基本上就这些。这个实现覆盖了 Promises/A+ 的主要测试用例，包括异步回调、链式调用、错误捕获、循环引用检测等。关键是理解 resolvePromise 如何递归解析 thenable，以及 queueMicrotask 确保回调异步执行，模拟原生 microtask 队列行为。

以上就是手写一个符合Promises/A+规范的Promise_js深度探索的详细内容，更多请关注php中文网其它相关文章！