Promise A+ 规范实战：打造一个可靠的 Promise 实现

2023-12-04 10:01:30

前言

在异步编程中，Promise 是一种非常有用的工具，它可以帮助我们轻松处理异步操作，并以一种更优雅的方式编写代码。为了确保 Promise 的可靠性和一致性，Promise A+ 规范应运而生。本文将带领您一步步实现一个符合 Promise A+ 规范的 Promise，并通过测试确保其可靠性。

一、了解 Promise A+ 规范

Promise A+ 规范定义了一系列 Promise 对象必须遵守的规则和行为。这些规则包括：

Promise 对象必须具有三种状态之一：Pending（等待）、Fulfilled（已完成）和 Rejected（已拒绝）。
Promise 对象只能从 Pending 状态转换到 Fulfilled 状态或 Rejected 状态，并且只能转换一次。
Promise 对象的 Fulfilled 状态和 Rejected 状态一旦确定，就不能再改变。
Promise 对象必须提供 then() 方法，该方法可以接受两个参数，分别是 onFulfilled 和 onRejected 函数。这两个函数将在 Promise 对象的状态发生改变时被调用。
onFulfilled 和 onRejected 函数可以返回一个值或一个 Promise 对象。如果返回一个值，则该值将成为下一个 then() 方法的返回值。如果返回一个 Promise 对象，则该 Promise 对象的状态改变时，下一个 then() 方法的相应函数才会被调用。

二、实现 Promise 对象

根据 Promise A+ 规范，我们可以一步步实现一个 Promise 对象：

定义 Promise 构造函数

function Promise(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((callback) => {
        callback(value);
      });
    }
  };

  const reject = (reason) => {
    if (this.state === 'pending') {
      this.state = 'rejected';
      this.reason = reason;
      this.onRejectedCallbacks.forEach((callback) => {
        callback(reason);
      });
    }
  };

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

定义 then() 方法

Promise.prototype.then = function (onFulfilled, onRejected) {
  return new Promise((resolve, reject) => {
    if (this.state === 'fulfilled') {
      setTimeout(() => {
        const value = onFulfilled(this.value);
        resolve(value);
      }, 0);
    } else if (this.state === 'rejected') {
      setTimeout(() => {
        const reason = onRejected(this.reason);
        reject(reason);
      }, 0);
    } else {
      this.onFulfilledCallbacks.push((value) => {
        setTimeout(() => {
          const value = onFulfilled(this.value);
          resolve(value);
        }, 0);
      });

      this.onRejectedCallbacks.push((reason) => {
        setTimeout(() => {
          const reason = onRejected(this.reason);
          reject(reason);
        }, 0);
      });
    }
  });
};