异步编程 Promise：从使用到手写实现（4200字长文）

这是我参与更文挑战的第27天，活动详情查看： 更文挑战

本文介绍了 Promise 如何解决回调地狱的问题，了解 Promise 和微任务的渊源，然后带你一步一步的解构手写实现一个简单的 Promise，最后简单介绍并手写实现了一些 Promise 的 API，包括 Promise.all、Promise.allSettled、Promise.race、Promise.finally 等API。

了解 Promise

Promise 是异步编程的一种解决方案，ES6 新增的一个对象，用来传递 异步操作 的消息。它代表了某个未来才会知道结果的事件（通常是一个异步操作），并且这个事件提供统一的 API，可供进一步处理。

Promise 有以下两个特点：

• Promise 的状态不受外界影响。Promise 翻译过来是承诺的意思，这个承诺会在未来有一个确切的答复，并且该承诺有三种状态，分别是：等待中 pending、 已完成 resolved、 已失败 rejected。它代表一个异步操作，只有 异步操作的结果 可以决定当前是哪一种状态，任何其他操作都无法改变这个状态。
• Promise 一旦由等待状态变成为其他状态就永远 不能更改为其他状态 了。也就是说，当状态从 pending 变为 resolved 或者 rejected 后，状态就不能更改了。

new Promise((resolve, reject) => {
  resolve("resolve");
  reject("reject"); // 这个reject无效
});
复制代码

在构造 Promise 的时候，构造函数内部的代码是立即执行的：

new Promise((resolve, reject) => {
  console.log(1);
  resolve("resolve");
});
console.log(2);

// 先后输出：1 2
复制代码

Promise 很好地解决了 回调地狱 的问题，使代码可以变得更加简洁优雅。

Promise 也存在一些缺点：

• 它一旦新建就会立即执行，无法中途取消；
• 错误是需要通过回调函数捕获。

编码风格问题：回调地狱

Promise 解决的是 异步编码风格 的问题，即 回调地狱 的问题：

如下代码：

ajax(url, () => {
  // 处理逻辑
  ajax(url1, () => {
    // 处理逻辑
    ajax(url2, () => {
      // 处理逻辑
    })
  })
})
复制代码

回调地狱主要有两个问题：

• 第一是 嵌套调用，后面的任务依赖上个任务的请求结果，并在 上个任务的回调函数内部执行新的业务逻辑，当嵌套层次多了之后代码的可读性会变得非常差。
• 第二是 任务的不确定性，执行每个任务都有两种可能的结果（成功或者失败），所以体现在代码中就需要对每个任务的执行结果做两次判断，这种对每个任务都要进行一次额外的错误处理的方式，明显增加了代码的混乱程度。

分析出原因所在，则解决思路就清晰了：

• 第一是 消灭嵌套调用；
• 第二是 合并多个任务的错误处理。

下面来了解 Promise 是如何来解决嵌套调用（回调地狱）的问题和如何处理多次错误的。

解决嵌套调用

Promise 主要通过下面两步解决嵌套回调问题的：

• 首先，Promise 通过 then 实现了回调函数的延时绑定。

回调函数的 延时绑定 在代码上的体现就是先创建 Promise 对象 p1，通过 Promise 的构造函数 executor 来执行业务逻辑；创建好 Promise 对象 p1 之后，再使用 p1.then 来设置回调函数。

示范代码如下：

// 创建Promise对象p1，并在executor函数中执行业务逻辑
function executor(resolve, reject) {
  resolve(100)
}
let p1 = new Promise(executor)
// p1 延迟绑定回调函数 onResolve
function onResolve(value) {
  console.log(value)
}
p1.then(onResolve)
复制代码

• 其次，需要将回调函数 onResolve 的返回值穿透到最外层

我们会根据 onResolve 函数的传入值来决定创建什么类型的 Promise 任务，创建好的 Promise 对象需要返回到最外层，这样就可以摆脱嵌套循环了。

可以看下面的代码：

处理异常

如下代码：

function executor(resolve, reject) {
  let rand = Math.random();
  console.log(1)
  console.log(rand)
  if (rand > 0.5)
    resolve()
  else
    reject()
}
var p0 = new Promise(executor);

var p1 = p0.then((value) => {
  console.log("succeed-1")
  return new Promise(executor)
})

var p3 = p1.then((value) => {
  console.log("succeed-2")
  return new Promise(executor)
})

var p4 = p3.then((value) => {
  console.log("succeed-3")
  return new Promise(executor)
})

p4.catch((error) => {
  console.log("error")
})
console.log(2)
复制代码

这段代码有四个 Promise 对象：p0～p4。无论哪个对象里面抛出异常，都可以通过最后一个对象 p4.catch 来捕获异常，通过这种方式可以 将所有 Promise 对象的错误合并到一个函数来处理，这样就解决了每个任务都需要单独处理异常的问题。

之所以可以使用最后一个对象来捕获所有异常，是因为 Promise 对象的错误具有 冒泡 性质，会一直向后传递，直到被 onReject 函数处理或 catch 语句捕获为止。具备了这样 冒泡 的特性后，就不需要在每个 Promise 对象中单独捕获异常了。

通过这种方式消灭了 嵌套调用和频繁的错误处理，使得我们写出来的代码更加优雅，更加符合人的线性思维。

Promise 的链式调用

promise 构造函数内是同步执行的， 通过 then 实现链式调用，then 方法是异步执行的。

new Promise(function (resolve, reject) {
  resolve(1);
})
  .then(function (data) {
    console.log(data);
    return 2; // 包装成 Promise.resolve(2)
  })
  .then(function (data) {
    console.log(data);
  })
  .catch(function (err) {
    console.log(err);
  });
复制代码

Promise 与微任务

Promise 和微任务的关系到底体现哪里呢？可以结合下面这个简单的 Promise 代码来回答这个问题：

function executor(resolve, reject) {
  resolve(100)
}
let demo = new Promise(executor)
function onResolve(value) {
  console.log(value)
}
demo.then(onResolve)
复制代码

执行顺序如下：

1. 首先执行 new Promise 时，Promise 的构造函数会被执行，不过由于 Promise 是 V8 引擎提供的，所以暂时看不到 Promise 构造函数的细节。
2. 接下来，Promise 的构造函数会调用 Promise 的参数 executor 函数。然后在 executor 中执行了 resolve，resolve 函数也是在 V8 内部实现的，那么 resolve 函数到底做了什么呢？
3. 我们知道，执行 resolve 函数，会触发 demo.then 设置的回调函数 onResolve，所以可以推测，resolve 函数内部调用了通过 demo.then 设置的 onResolve 函数。
4. 这里需要注意一下，由于 Promise 采用了 回调函数延迟绑定技术，所以在执行 resolve 函数的时候，回调函数还没有绑定，那么只能推迟回调函数的执行。

Promise 中为什么要引入微任务？

由于 promise 采用 .then 延时绑定回调机制，而 new Promise 时又需要直接执行 promise 中的方法，即发生了先执行方法后添加回调的过程，此时需等待 then 方法绑定两个回调后才能继续执行方法回调，便可将回调添加到当前js调用栈中执行结束后的任务队列中，由于宏任务较多容易堵塞，则采用了微任务。

Promise 中是如何实现回调函数返回值穿透的？

首先 Promise 的执行结果保存在 promise 的 data 变量中，然后是 .then 方法返回值 为使用 resolved 或 rejected 回调方法新建的一个 promise 对象，如成功则返回new Promise(resolved)，将前一个promise的 data 值赋给新建的 promise。

Promise 出错后，是怎么通过“冒泡”传递给最后那个捕获异常的函数？

promise 内部有 resolved_ 和 rejected_ 变量保存成功和失败的回调，进入.then(resolved，rejected)时会判断 rejected 参数是否为函数，若是函数，错误时使用 rejected处理错误；若不是，则错误时直接 throw 错误，一直传递到最后的捕获，若最后没有被捕获，则会报错。可通过监听 unhandledrejection 事件捕获未处理的 promise 错误。

Promise 的实现解构

看 Promise 结构思考问题

先看看这个 Promise 的结构：

new Promise(function (resolve, reject) {
  resolve(1);
  // reject(2);
}).then(function (data) {
  // console.log(data);
});
复制代码

思考以下问题：

• Promise 传进去一个函数 fn，函数里面怎么处理呢？
• Promise 内部是同步立即执行的，那么fn 函数应该是直接执行？
• 函数的两个参数也是函数：resolve、reject
• 用 try...catch...？catch 捕获的肯定是执行 reject 函数了
• then 函数（链式调用）怎么实现呢？
• resolve 函数即 then 的第一个参数
• reject 可以当做 then 的第二个参数

定义状态常量

首先，创建三个表示状态的常量：

const PENDING = "pending";
const RESOLVED = "resolved";
const REJECTED = "rejected";
复制代码

搭建构造函数的框架

function myPromise(fn) {
  // 传入的是一个函数
  // 定义一个常量that来缓存当前的this对象
  const that = this;
  // 初始状态是pending
  that.status = PENDING;
  // 定义一个变量来保存resolve或者reject传入的值
  that.params = null;
  // 定义两个数组来记录异步操作之后回来执行的函数（即保存then中的回调函数，等状态改变时执行）
  that.resolvedCallBacks = []; // 状态转为成功之后执行的函数
  that.rejectedCallBacks = []; // 状态转为失败之后执行的函数
  // 定义resolve函数
  function resolve() {}
  // 定义reject函数
  function reject() {}
  // 执行fn函数
  fn();
}
复制代码

完善 resolve 和 reject 函数

// 定义resolve函数
function resolve(params) {
  // 只有状态为初始状态时才执行
  if (that.status === PENDING) {
    that.status = RESOLVED; // 执行之后状态改为成功
    that.params = params; // 记录传入的参数
    // 遍历回调函数并执行
    that.resolvedCallBacks.map(function (callback) {
      callback && callback(that.params);
    });
  }
}
// 定义reject函数
function reject(params) {
  // 只有状态为初始状态时才执行
  if (that.status === PENDING) {
    that.status = REJECTED; // 执行之后状态改为失败
    that.params = params; // 记录传入的参数
    // 遍历回调函数并执行
    that.resolvedCallBacks.map(function (callback) {
      callback && callback(that.params);
    });
  }
}
复制代码

执行 fn 函数

执行 fn 函数时，把 resolve 和 reject 当做参数传入，捕捉到错误后执行 reject 函数：

// 执行fn函数
try {
  fn(resolve, reject);
} catch (e) {
  reject(e);
}
复制代码

链式调用 then 的实现

在 Promise 的原型上扩展 then 函数，通过延迟回调绑定技术实现链式调用：

• then 函数有两个参数 onFulfilled、 onRejected (参数为函数)
• 当前实例状态变成成功状态时，onFulfilled 作为回调函数被调用
• 当前实例状态变成失败状态时，onRejected 作为回调函数被调用
• 其实就是把对应状态的函数加进回调数组中，等 fn() 函数执行完后执行回调

myPromise.prototype.then = function (onFulfilled, onRejected) {
  let that = this;
  // console.log(that.status);
  // 当状态为 PENDING 时，把 onFulfilled 和 onRejected 加进对应数组中
  if (that.status === PENDING) {
    that.resolvedCallbacks.push(onFulfilled);
    that.rejectedCallbacks.push(onRejected);
    // console.log(that.rejectedCallbacks, that.resolvedCallbacks);
  }
  // 当状态为 RESOLVED 时，执行 onFulfilled
  if (that.status === RESOLVED) {
    onFulfilled(that.params);
  }
  // 当状态为 RESOLVED 时，执行 onRejected
  if (that.status === REJECTED) {
    onRejected(that.params);
  }
};
复制代码

完整的 Promise 函数实现

完整的 Promise 函数实现如下：

// 定义promise的三个状态
const PENDING = "PENDING";
const RESOLVED = "RESOLVED";
const REJECTED = "REJECTED";
function myPromise(fn) {
  // 当前执行上下文
  let that = this;
  // 初始状态是pending
  that.status = PENDING;
  // 参数
  that.params = null;
  // 定义两个回调数组：存储 resolve 和 reject 要执行的函数(then传进来的函数)
  that.resolvedCallbacks = [];
  that.rejectedCallbacks = [];

  // 定义resolve函数
  function resolve(params) {
    // 只有状态为PENDING时才可以操作
    if (that.status === PENDING) {
      // 修改状态
      that.status = RESOLVED;
      that.params = params;
      // console.log('我是resolve函数');
      // 遍历执行函数
      that.resolvedCallbacks.map((cb) => cb(that.params));
    }
  }

  // 定义rejected函数
  function reject(params) {
    // 只有状态为PENDING时才可以操作
    if (that.status === PENDING) {
      that.status = REJECTED;
      that.params = params;
      // console.log('我是reject函数');
      // 遍历执行函数
      that.rejectedCallbacks.map((cb) => cb(that.params));
    }
  }

  // 执行fn()
  try {
    fn(resolve, reject);
    // console.log('我是fn函数');
  } catch (err) {
    reject(err);
  }
}
// 通过 then 实现链式调用
myPromise.prototype.then = function (onFulfilled, onRejected) {
  let that = this;
  // console.log(that.status);
  // 当状态为 PENDING 时，把 onFulfilled 和 onRejected 加进对应数组中
  if (that.status === PENDING) {
    that.resolvedCallbacks.push(onFulfilled);
    that.rejectedCallbacks.push(onRejected);
    // console.log(that.rejectedCallbacks, that.resolvedCallbacks);
  }
  // 当状态为 RESOLVED时，执行 onFulfilled
  if (that.status === RESOLVED) {
    onFulfilled(that.params);
  }
  // 当状态为 RESOLVED时，执行 onRejected
  if (that.status === REJECTED) {
    onRejected(that.params);
  }
};
复制代码

以上就是简易版的 Promise 实现了，来运行一下：

new myPromise(function (resolve, reject) {
  resolve(1);
  // reject(2);
}).then(
  function (data) {
    console.log(data);
  },
  function (err) {
    console.log(err);
  }
);
复制代码

Promise 的一些 API

Promise.all

所有都成功才成功 resolve ，只要有一个失败就马上返回失败 reject。

Promise.all() 接受一个 promise 的 iterable (一个可迭代对象，如 Array 或 String)类型的输入，可以同时处理多个 promise 任务。它等待所有任务都完成才返回，或有第一个失败即返回。

• 当所有的任务都执行完成时，Promise.all() 返回 resolve；
• 但当有一个失败(reject)，则返回失败的信息，即使其他 promise 执行成功，也会返回失败。

const promise1 = Promise.resolve(3);
const promise2 = 42;
const promise3 = new Promise((resolve, reject) => {
  setTimeout(resolve, 100, "foo");
});
Promise.all([promise1, promise2, promise3]).then((values) => {
  console.log(values); // [3, 42, "foo"]
});
复制代码

Promise.all() 适合 Promise 彼此依赖时或其中任何一个 rejected 时立即结束的场景。

Promise.all() 的模拟实现：

function promiseAll(promises) {
  return new Promise(function (resolve, reject) {
    // 参数不是数据则返回错误
    if (!Array.isArray(promises)) {
      return reject(new TypeError("argument must be anarray"));
    }
    let dealNum = 0;
    let pLen = promises.length;
    let res = new Array(pLen);
    for (let i = 0; i < pLen; i++) {
      Promise.resolve(promises[i]).then(
        function (value) {
          dealNum++;
          res[i] = value; // 按顺序记录执行结果
          if (dealNum === pLen) {
            return resolve(res); // 全部执行完成返回结果
          }
        },
        function (err) {
          return reject(err); // 有一个出错就结束返回
        }
      );
    }
  });
}
复制代码

使用验证

let p1 = Promise.resolve(1);
let p2 = new Promise(function (resolve, reject) {
  setTimeout(function () {
    resolve(2);
  }, 200);
});
let p3 = Promise.resolve(3);
promiseAll([p1, p2, p3]).then(function (res) {
  console.log(res);
});
复制代码

Promise.all() 的错误处理：

有时候我们使用 Promise.all() 执行很多个网络请求，可能有一个请求出错，但我们并不希望其他的网络请求也返回 reject，要错都错，这样显然是不合理的。

如何做才能做到 promise.all 中即使一个 promise 程序 reject，promise.all 依然能把其他数据正确返回呢?

解决办法：将错误特殊处理也返回 resolve；即当 promise 捕获到 error 的时候，代码吃掉这个异常，返回 resolve，约定特殊格式表示这个调用成功了。
​

let p4 = new Promise(function (resolve, reject) {
  setTimeout(function () {
    resolve(4);
  }, 0);
});
let p5 = new Promise(function (resolve, reject) {
  setTimeout(function () {
    resolve(5);
  }, 200);
});
let p6 = new Promise(function (resolve, reject) {
  setTimeout(function () {
    try {
      console.log(XX.BBB);
    } catch (exp) {
      resolve("error"); // 即使是错误，也返回 resolve
    }
  }, 100);
});
Promise.all([p4, p5, p6])
  .then(function (results) {
    console.log("success");
    console.log(results);
  })
  .catch(function (r) {
    console.log("err");
    console.log(r);
  });
复制代码

还有一种方法是通过 Promise.allSettled 来处理

Promise.allSettled

当 Promise 彼此不依赖时，例如有 3 个 Promise ： p1、 p2、p3，p1 和 p3 的结果是重要的，p2 失败也不能影响的，那这个时候可以用 Promise.allSettled。

Promise.allSettled() 方法返回一个在所有给定的 promise 都已经 fulfilled 或 rejected 后的 promise ，并带有一个对象数组，每个对象表示对应的 promise 结果。

const promise1 = Promise.resolve(3);
const promise2 = 42;
const promise3 = new Promise((resolve, reject) => {
  setTimeout(resolve, 100, "foo");
});
const promise4 = new Promise((resolve, reject) => {
  reject("我会rejected的");
});
Promise.allSettled([promise1, promise2, promise3, promise4]).then((res) => {
  console.log(res);
});
复制代码

每个结果对象都有一个 status ，如果为 fulfilled ，则为成功的， value 为成功后返回的值；如果为 rejected，则是失败的， reason 为失败后返回的值。

Promise.race

与 Promise.all() 的区别：

• Promise.all 可以将多个实例组装成一个新的实例，成功的时候返回一个成功数组，失败的时候则返回最先被 reject 失败状态的值
• race 是赛跑的意思，即 Promise.race([p1, p2, p3]) 里面的结果哪个获取的快，就返回哪个结果，不管结果本身是成功还是失败

模拟实现 Promise.race()：

Promise.prototype.myRace = function (list) {
  return new Promise((resolve, reject) => {
    list.forEach((item) => {
      Promise.resolve(item).then(resolve, reject);
    });
  });
};
复制代码

Promise.finally

finally 的作用：

• 在 promise 结束时，无论结果是 resolved 或者是 rejected ，都会执行指定的回调函数。

模拟实现 Promise.finally：

Promise.prototype.finally = function (callback) {
  let Fn = this.constructor;
  return this.then(
    (res) => Fn.resolve(callback()).then(() => res),
    (err) =>
      Fn.resolve(callback()).then(() => {
        throw err;
      })
  );
};
复制代码

总结

• 产生 回调地狱 的原因是：
  • 回调函数存在多层嵌套调用 的问题；
  • 每种任务的 处理结果存在两种可能性（成功或失败），那么需要在每种任务执行结束后分别处理这两种可能性。
• Promise 通过 回调函数延迟绑定、回调函数返回值穿透和错误冒泡技术 解决了上面的两个问题。
• Promise 之所以 要使用微任务 是由 Promise 回调函数延迟绑定技术导致的。
• 通过 Promise 的手写实现可以进一步理解 Promise。
• 最后还介绍了一些 Promise 常用的 API。