手写一个Promise并通过Promise A+规范测试

发表于 2020-06-12 更新于 2023-02-13 分类于编程本文字数： 2.9k 阅读时长 ≈ 10 分钟

手写一个Promise并通过Promise A+规范测试。

`Promise`构造函数

在规范中，有一段

the core Promises/A+ specification does not deal with how to create, fulfill, or reject promises, choosing instead to focus on providing an interoperable then method. Future work in companion specifications may touch on these subjects.

可以看出，规范并没有指出如何创建一个Promise，而是规范then方法的行为。

而在 ES6 中创建一个Promise是通过new Promise(executor)来实现的。具体可以看 MDN 上对 Promise 的解释。

Promise - JavaScript | MDN

所以我们也从这一个角度入手，创建一个我们自己的Promise构造函数，命名为MyPromise。

1
2
3

function MyPromise() {
  // ...
}

ES6的Promise构造函数需要传入一个executor函数，该函数在Promise内部会立即执行。

所以我们的构造函数也传入一个executor函数。

1
2
3

function MyPromise(executor) {
  // ...
}

规范中提到：

A promise must be in one of three states: pending, fulfilled, or rejected.

也就是一个Promise必须为三个状态中的其中一个。

OK，那我们定义三个状态的常量来表示：

// pending状态
const PENDING = "pending";
// resolved状态
const RESOLVED = "resolved";
// rejected状态
const REJECTED = "rejected";

接下来我们应该初始化一个Promise对象上的一些属性。

function MyPromise(executor) {
  // 以self指向this，方便等会在函数内的操作。
  const self = this;
  // 初始化状态为pending
  self.$status = PENDING;
  // 初始化数据为undefined
  self.$data = undefined;
  // 初始化一个成功的回调数组
  self.$onResolvedCallbacks = [];
  // 初始化一个失败的回调数组
  self.$onRejectedCallbacks = [];
}

对于传入的executor函数，有两个参数：

resolve 完成这个Promise的函数；
reject 拒绝这个Promise的函数；

所以我们在构造函数的内部需要实现这两个函数，并且在执行executor函数时，传进这两个函数。

在ES6的Promise实现中，一般我们会这么使用Promise

var promise = new Pormise(function (resolve, reject) {
  // 成功就调用resolve，并传进一个成功的值
  // 失败就调用reject，传进失败的原因
  resolve(1);
});

promise.then((res) => {
  console.log(res); // 打印1
});

所以我们的实现也模仿它。

记住，Promise只能是三个状态中的一个，并且只能从：

pending -> resolved
pending -> rejected

function MyPromise(executor) {
  // 以self指向this，方便等会在函数内的操作。
  const self = this;
  // 初始化状态为pending
  self.$status = PENDING;
  // 初始化数据为undefined
  self.$data = undefined;
  // 初始化一个成功的回调数组
  self.$onResolvedCallbacks = [];
  // 初始化一个失败的回调数组
  self.$onRejectedCallbacks = [];

  // 解决本Promise的函数，参数为解决的值
  function resolve(value) {
    if (self.$status === PENDING) {
      self.$status === RESOLVED;
      self.$data = value;
      self.$onResolvedCallbacks.forEach((fn) => {
        fn(value);
      });
    }
  }

  // 拒绝本Promise的函数，参数为拒绝的原因
  function reject(reason) {
    if (self.$status === PENDING) {
      self.$status === REJECTED;
      self.$data = reason;
      self.$onRejectedCallbacks.forEach((fn) => {
        fn(reason);
      });
    }
  }
}

两个函数都被if判定的语句包裹，防止一个已经resolve的Promise对象被reject，或者已经被reject的Promise对象被resolve。

其实这么写还是有问题的，不过后面再说。

现在我们的构造函数基本完成了大部分的工作，最后的一步就是执行executor函数，并传入resolve和reject函数了。

function MyPromise(executor) {
  // 以self指向this，方便等会在函数内的操作。
  const self = this;
  // 初始化状态为pending
  self.$status = PENDING;
  // 初始化数据为undefined
  self.$data = undefined;
  // 初始化一个成功的回调数组
  self.$onResolvedCallbacks = [];
  // 初始化一个失败的回调数组
  self.$onRejectedCallbacks = [];

  // 解决本Promise的函数，参数为解决的值
  function resolve(value) {
    if (self.$status === PENDING) {
      self.$status === RESOLVED;
      self.$data = value;
      self.$onResolvedCallbacks.forEach((fn) => {
        fn(value);
      });
    }
  }

  // 拒绝本promise的函数，参数为拒绝的原因
  function reject(reason) {
    if (self.$status === PENDING) {
      self.$status === REJECTED;
      self.$data = reason;
      self.$onRejectedCallbacks.forEach((fn) => {
        fn(reason);
      });
    }
  }

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

为什么执行executor函数要放在try-catch中呢？

因为如果executor执行过程出错我们希望以出错的原因来拒绝这个Promise。

ES6的实现也是如此。

var promise = new Promise(function (resolve, reject) {
  throw new Error();
});

promise.then(null, (err) => {
  console.log("出错啦~"); // 打印
});

`Promise`对象的`then`函数

每一个Promise对象都可以调用它的then方法来注册回调函数，所以then方法要写在构造函数的原型对象上：

1
2
3

MyPromise.prototype.then = function () {
  // ...
};

在规范2.2.1中，提到then方法需要有两个参数：

A promise’s then method accepts two arguments:
promise.then(onFulfilled, onRejected)

onFulfilled：Promise被解决时的回调。（下文用onResolved代替，都是一个意思的。）
onRejected：promise被拒绝时的回调。

所以我们的then方法也传进这两个参数：

1
2
3

MyPromise.prototype.then = function (onResolved, onRejected) {
  // ...
};

紧接着，规范说明这两个参数都是可选的，当不是函数的时候要进行忽略。所以在函数的内部要进行判断。

MyPromise.prototype.then = function (onResolved, onRejected) {
  onResolved =
    typeof onResolved === "function"
      ? onResolved
      : function (value) {
          return value;
        };
  onRejected =
    typeof onRejected === "function"
      ? onRejected
      : function (err) {
          throw err;
        };
};

规范2.2.7说明then方法必须返回一个新的Promise对象。

then must return a promise.
promise2 = promise1.then(onFulfilled, onRejected);

因为Promise有三个状态，所以我们需要为每一个状态编写返回函数：

MyPromise.prototype.then = function (onResolved, onRejected) {
  onResolved =
    typeof onResolved === "function"
      ? onResolved
      : function (value) {
          return value;
        };
  onRejected =
    typeof onRejected === "function"
      ? onRejected
      : function (err) {
          throw err;
        };

  // Promise状态为resolved时
  if (this.$status === RESOLVED) {
    return new MyPromise(function (resolve, reject) {
      // ...
    });
  }

  // Promise状态为rejected时
  if (this.$status === REJECTED) {
    return new MyPromise(function (resolve, reject) {
      // ...
    });
  }

  // Promise状态为pending时
  if (this.$status === PENDING) {
    return new MyPromise(function (resolve, reject) {
      // ...
    });
  }
};

规范2.2.7.1 - 2.2.7.4 说明了then方法放回的Promise的状态如何根据传入函数（onFulfilled, onRejected）的返回值决定。

If either onFulfilled or onRejected returns a value x, run the Promise Resolution Procedure [[Resolve]](promise2, x).
If either onFulfilled or onRejected throws an exception e, promise2 must be rejected with e as the reason.
If onFulfilled is not a function and promise1 is fulfilled, promise2 must be fulfilled with the same value as promise1.
If onRejected is not a function and promise1 is rejected, promise2 must be rejected with the same reason as promise1.

这里的重点时如何根据返回值x来决定返回的Promise的状态，这里需要引出第一点的[[Resolve]](promise2, x)这个函数。

这个函数在2.3有详细的介绍，这里我们先不去管函数的内部如何实现，我们只要明白，这个函数根据x来决定promise2的状态。

/**
 * @promise 需要决定的promise
 * @x       决定promise的x
 * @resolve promise的解决函数
 * @reject  promise的拒绝函数
 */
function PromiseResolution(promise, x, resolve, reject) {
  // ...
}

现在返回Promise的内部就可以写了，对于三个状态：

resolved状态，直接调用then注册的onResolved函数即可。
rejected状态，直接调用then注册的onRejected函数即可。
pending状态，需要在状态变更的时候，调用注册的函数，也就是往$onResolvedCallbacks和$onRejectedCallbacks中储存一个函数。

并且规范2.2.4以及3.1指出onResolved和onRejected必须异步的执行，所以我们要包裹函数内的操作：

MyPromise.prototype.then = function (onResolved, onRejected) {
  const self = this;
  let promise;

  onResolved =
    typeof onResolved === "function"
      ? onResolved
      : function (value) {
          return value;
        };
  onRejected =
    typeof onRejected === "function"
      ? onRejected
      : function (err) {
          throw err;
        };

  // Promise状态为resolved时
  if (this.$status === RESOLVED) {
    return (promise = new MyPromise(function (resolve, reject) {
      setTimeout(() => {
        try {
          // 这里和状态为rejected的区别为调用的回调函数不同。
          const res = onResolved(self.$data);
          PromiseResolution(promise, res, resolve, reject);
        } catch (e) {
          reject(e);
        }
      }, 0);
    }));
  }

  // Promise状态为rejected时
  if (this.$status === REJECTED) {
    return (promise = new MyPromise(function (resolve, reject) {
      setTimeout(() => {
        try {
          const res = onRejected(self.$data);
          PromiseResolution(promise, res, resolve, reject);
        } catch (e) {
          reject(e);
        }
      }, 0);
    }));
  }

  // Promise状态为pending时
  if (this.$status === PENDING) {
    return (promise = new MyPromise(function (resolve, reject) {
      self.$onResolvedCallbacks.push(function (value) {
        try {
          const res = onResolved(value);
          PromiseResolution(promise, res, resolve, reject);
        } catch (e) {
          reject(e);
        }
      });

      self.$onRejectedCallbacks.push(function (err) {
        try {
          const res = onRejected(err);
          PromiseResolution(promise, res, resolve, reject);
        } catch (e) {
          reject(e);
        }
      });
    }));
  }
};

至此，我们的主体代码部分基本完成，最后就差PromiseResolution这个函数的实现了。
这个函数的实现在规范中其实说的很详细，只要按着要求来基本就没啥大问题了。

function PromiseResolution(promise, x, resolve, reject) {
  // 2.3.1 如果promise和x为同一个对象，就以TypeError来拒绝promise
  if (promise === x) {
    reject(new TypeError());
    return;
  }

  // 2.3.2.1 - 2.3.2.3 如果x是原生的Promise，那么就以x的最终的情况来决定promise
  if (x instanceof Promise) {
    x.then(resolve, reject);
  }
  // 2.3.3 如果x是一个对象或者函数
  else if (x !== null && (typeof x === "object" || typeof x === "function")) {
    let then;
    try {
      // 2.3.3.1 尝试取x的then属性
      then = x.then;
    } catch (e) {
      // 2.3.3.2 如果取then属性出错，则以这个原因拒绝promise
      reject(e);
      return;
    }
    // 2.3.3.3 如果then属性为一个函数
    if (typeof then === "function") {
      let whoCall = false;
      try {
        // 2.3.3.3 以x为上下文调用then，并以它的结果来决定promise，whoCall的作用是防止多次的改变promise的值，
        then.call(
          x,
          (y) => {
            if (!whoCall) {
              // 2.3.3.3.1 以y再次来尝试决定promise
              whoCall = true;
              PromiseResolution(promise, y, resolve, reject);
            }
          },
          (err) => {
            if (!whoCall) {
              // 2.3.3.3.2 以err直接拒绝promise
              whoCall = true;
              reject(err);
            }
          }
        );
      } catch (e) {
        if (!whoCall) {
          // 2.3.3.3.4.1 - 2.3.3.3.4.2 如果调用then出错，就以这个出错信息直接拒绝promise
          whoCall = true;
          reject(e);
        }
      }
    } else {
      // 2.3.3.4 then不是函数，直接以x为值来解决promise
      resolve(x);
    }
  } else {
    // 2.3.4 x不是一个对象或者函数，直接以x为值来解决promise
    resolve(x);
  }
}

至此，我们的Promise实现基本完成。

但是如果以下面的代码来测试我们的Promise的话，会发现无法打印：

const promise = new MyPromise(function (resolve, reject) {
  resolve(1);
});

promise.then((res) => {
  console.log(res); // 无法打印
});

这是为什么呢，重点就是我们在构造函数内部的resolve和reject函数，它们是同步，也就是：

const promise = new MyPromise(function (resolve, reject) {
  resolve(1);
});
// 这里就已经遍历$onResolvedCallbacks或者$onRejectedCallbacks数组并执行了
// 而下面的注册的回调还没执行，导致了这个问题
promise.then((res) => {
  console.log(res); // 无法打印
});

解决的办法就是以异步的形式来解决Promise，以一个新的任务来解决Promise，也就是包裹在setTimeout中即可。

测试

现在来使用Promise/A+官方给定的测试数据来测试这个实现。

github：测试脚本

我们根据README.md，其实很简单，就是配置一个依赖，然后运行特定的命令即可。

首先先创建一个项目，使用npm init来初始化，package.json使用默认的即可。

接着导入这个库。

{
  // ...
  "devDependencies": {
    "promises-aplus-tests": "*"
  }
  // ...
}

接着配置我们的script命令

{
  // ...
  "devDependencies": {
    "promises-aplus-tests": "*"
  },
  "scripts": {
    // 这里的test/index.js修改成你想测试的文件路径
    "test": "promises-aplus-tests test/index.js"
  }
}

最后，需要以一个es6 module的形式来导出一个对象：

// ...你的实现

const deferred = function () {
  let defer = {};
  defer.promise = new MyPromise((resolve, reject) => {
    defer.resolve = resolve;
    defer.reject = reject;
  });
  return defer;
};

module.exports = {
  deferred,
};

接着，就可以运行npm test的来进行愉快地测试了。

附上完整的代码：

const PENDING = "pending";
const RESOLVED = "resolved";
const REJECTED = "rejected";

/**
 * @param executor 将会在未来执行的函数。
 * @constructor Promise构造函数
 */
function MyPromise(executor) {
  const self = this;

  self.$status = PENDING;
  self.$data = undefined;
  self.$onResolvedCallbacks = [];
  self.$onRejectedCallbacks = [];

  function resolve(value) {
    setTimeout(() => {
      if (self.$status === PENDING) {
        self.$status = RESOLVED;
        self.$data = value;
        self.$onResolvedCallbacks.forEach((fn) => {
          fn(value);
        });
      }
    }, 0);
  }

  function reject(err) {
    setTimeout(() => {
      if (self.$status === PENDING) {
        self.$status = REJECTED;
        self.$data = err;
        self.$onRejectedCallbacks.forEach((fn) => {
          fn(err);
        });
      }
    }, 0);
  }

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

MyPromise.prototype.then = function (onResolved, onRejected) {
  const self = this;
  let promise2;

  onResolved =
    typeof onResolved === "function"
      ? onResolved
      : function (value) {
          return value;
        };
  onRejected =
    typeof onRejected === "function"
      ? onRejected
      : function (err) {
          throw err;
        };

  if (self.$status === RESOLVED) {
    return (promise2 = new MyPromise(function (resolve, reject) {
      setTimeout(() => {
        try {
          const res = onResolved(self.$data);
          PromiseResolve(promise2, res, resolve, reject);
        } catch (e) {
          reject(e);
        }
      }, 0);
    }));
  }

  if (self.$status === REJECTED) {
    return (promise2 = new MyPromise(function (resolve, reject) {
      setTimeout(() => {
        try {
          const res = onRejected(self.$data);
          PromiseResolve(promise2, res, resolve, reject);
        } catch (e) {
          reject(e);
        }
      }, 0);
    }));
  }

  if (self.$status === PENDING) {
    return (promise2 = new MyPromise(function (resolve, reject) {
      self.$onResolvedCallbacks.push(function (value) {
        try {
          const res = onResolved(value);
          PromiseResolve(promise2, res, resolve, reject);
        } catch (e) {
          reject(e);
        }
      });

      self.$onRejectedCallbacks.push(function (err) {
        try {
          const res = onRejected(err);
          PromiseResolve(promise2, res, resolve, reject);
        } catch (e) {
          reject(e);
        }
      });
    }));
  }
};

function PromiseResolve(promise, x, resolve, reject) {
  if (promise === x) {
    reject(new TypeError());
    return;
  }

  if (x instanceof Promise) {
    x.then(resolve, reject);
  } else if (x !== null && (typeof x === "object" || typeof x === "function")) {
    let then;
    try {
      then = x.then;
    } catch (e) {
      reject(e);
      return;
    }
    if (typeof then === "function") {
      let whoCall = false;
      try {
        then.call(
          x,
          (y) => {
            if (!whoCall) {
              whoCall = true;
              PromiseResolve(promise, y, resolve, reject);
            }
          },
          (err) => {
            if (!whoCall) {
              whoCall = true;
              reject(err);
            }
          }
        );
      } catch (e) {
        if (!whoCall) {
          whoCall = true;
          reject(e);
        }
      }
    } else {
      resolve(x);
    }
  } else {
    resolve(x);
  }
}

module.exports = MyPromise;

附上自己地测试截图

Promise构造函数

Promise对象的then函数

测试

`Promise`构造函数

`Promise`对象的`then`函数