V8 Promise源码全面解读,其实你对Promise一无所知

296次阅读  |  发布于2年以前

写在前面的话

阅读本文你将收获什么?

你知道 浏览器 & Node 中真正的 Promise 执行顺序是怎么样的吗,如果你只是看过 Promise/A+ 规范的 Promise 实现,那么我肯定的告诉你,你对 Promise 执行顺序的认知是错误的。不信的话你就看看下面这两道题。

Promise.resolve().then(() => {
    console.log(0);
    return Promise.resolve(4)
}).then(res => {
    console.log(res);
})

Promise.resolve().then(() => {
    console.log(1);
}).then(() => {
    console.log(2);
}).then(() => {
    console.log(3);
}).then(() => {
    console.log(5);
}).then(() => {
    console.log(6);
})
// 0 1 2 3 4 5 6


new Promise((resolve, reject) => {
    Promise.resolve().then(() => {
        resolve({
            then: (resolve, reject) => resolve(1)
        });
        Promise.resolve().then(() => console.log(2));
    });
}).then(v => console.log(v));
// 2 1
复制代码

按照 Promise/A+ 规范来说,上面的代码打印的结果应该是 0 1 2 4 3 5 6,因为当 then 返回一个 Promise 的时候需要等待这个 Promise 完成后再同步状态和值给 then 的结果。

但是在 V8 甚至 各大支持 Promise 的主流浏览器中的执行结果都是 0 1 2 3 4 5 6

他们是如何做到与 Promise/A+ 规范不一样(也不能说一样,因为 Promise 没有明确描述他们的执行逻辑,只是给出一些规范)且保持一致的?

要知道, Promise 属于 JavaScript 中的一部分, 而 JavaScriptPromise 的实现规范并非来源于 Promise/A+,而是来自 ECMAScript 规范。

所以要知道这个问题的答案,我们不能仅仅看 Promise/A+ ,对于代码的执行过程和顺序我们的关注点应该是在 ECMAScript 或者 V8 上。

接下来我就结合 ECMAScript 规范来对 V8Promise 源码进行全面的解读。

还有三件事需要提前说一下:

1 . 本文更加适合有一定 Promise 基础的同学阅读,如果对 Promise 不了解的同学可以先看看这些文章

2 . 对于后续贴出的 c++ 代码大家只需要着重看带有中文注释的地方即可 3 . 因为代码块不会自动换行,所以建议 PC 端阅读可以有更好的阅读体验 4 . 文章很长,可以收藏,有时间静下心来慢慢看也可以。 5 . 点赞、点赞、点赞 进入正题

PromiseState

Promise 的 3 种状态,pendingfulfilledrejected ,源码如下[4]:

// Promise constants
extern enum PromiseState extends int31 constexpr 'Promise::PromiseState' {
  kPending,// 等待状态
  kFulfilled,// 成功状态
  kRejected// 失败状态
}
复制代码

一个新创建的 Promise 处于 pending 状态。当调用 resolvereject 函数后,Promise 处于 fulfilledrejected 状态,此后 Promise 的状态保持不变,也就是说 Promise 的状态改变是不可逆的,如果再次调用 resolve 或者 reject 将不会发生任何事,Promise 源码中出现了多处状态相关的 assert(断言),这个就不赘述了,想必对于 Promise 的三种状态大家都比较熟悉了。

JSPromise

JSPromise 描述 Promise 的基本信息,源码如下[5]:

bitfield struct JSPromiseFlags extends uint31 {
  // Promise 的状态,kPending/kFulfilled/kRejected
  status: PromiseState: 2 bit; 
  // 是否有onFulfilled/onRejected处理函数,
  // 没有调用过 then 方法的 Promise 没有处理函数
  //(catch方法的本质是then方法,后面会介绍)
  has_handler: bool: 1 bit; 
  handled_hint: bool: 1 bit; 
  async_task_id: int32: 22 bit;
}

@generateCppClass
extern class JSPromise extends JSObject {
  macro Status(): PromiseState {
    // 获取 Promise 的状态,返回 
    // kPending/kFulfilled/kRejected 中的一个
    return this.flags.status;
  }

  macro SetStatus(status: constexpr PromiseState): void {
    // 只有 pending 状态的 Promise 才可以被改变状态
    assert(this.Status() == PromiseState::kPending);
    // Promise 创建成功后,不可将 Promise 设置为 pending 状态
    assert(status != PromiseState::kPending);
    this.flags.status = status;
  }

  macro HasHandler(): bool {
    // 判断 Promise 是否有处理函数
    return this.flags.has_handler;
  }

  macro SetHasHandler(): void {
    this.flags.has_handler = true;
  }

  // promise 处理函数或结果,可以是:
  // 空
  // onFulfilled/onRejected构成的链表
  // promise的确认值(resolve的参数)
  reactions_or_result: Zero|PromiseReaction|JSAny;
  flags: SmiTagged<JSPromiseFlags>;
}
复制代码

Promise 状态改变时,比如调用了 resolve/reject 函数,SetStatus 方法会被调用;Javascript 层调用 resolve 方法时,reactions_or_result 字段会被赋值为 resolve 传入的参数;Javascript 层调用 then 方法时,说明已经有了处理函数,SetHasHandler() 会被调用。Status/SetStatus 这两个方法一个获取 Promise 状态,一个设置 Promise 状态;

其它

let p = new Promise((resolve, reject) => {
  resolve(123)
  // 会将 reactions_or_result 设置为 123
  // 会调用 SetHasHandler
  resolve(234)// 不会发生任何事,相当于没写
  reject(234)// 也不会发生任何事,相当于没写
})
复制代码

构造函数

构造函数源码如下[6]:

PromiseConstructor(
    js-implicit context: NativeContext, receiver: JSAny,
    newTarget: JSAny)(executor: JSAny): JSAny {
  // 1. 如果不存在 new 关键字, throw a TypeError exception.
  if (newTarget == Undefined) {
    ThrowTypeError(MessageTemplate::kNotAPromise, newTarget);
  }

  // 2. 如果传入的参数不是一个回调函数, throw a TypeError exception.
  if (!Is<Callable>(executor)) {
    ThrowTypeError(MessageTemplate::kResolverNotAFunction, executor);
  }

  let result: JSPromise;
  // 构造一个 Promise 对象
  result = NewJSPromise();
  // 从 Promise 对象身上,获取它的 resolve 和 reject 函数
  const funcs = CreatePromiseResolvingFunctions(result, True, context);
  const resolve = funcs.resolve;
  const reject = funcs.reject;
  try {
    // 直接同步调用 executor 函数,resolve 和 reject 做为参数
    Call(context, UnsafeCast<Callable>(executor), Undefined, resolve, reject);
  } catch (e) {
    // 如果出现异常则调用 reject 函数
    Call(context, reject, Undefined, e);
  }
  return result;
}
复制代码

首先分析两个 ThrowTypeError,以下代码可触发第一个 ThrowTypeError

Promise()  // Uncaught TypeError: undefined is not a promise
复制代码

原因是没有使用 new 操作符调用 Promise 构造函数,此时 newTarget 等于 Undefined,触发了 ThrowTypeError(MessageTemplate::kNotAPromise, newTarget)

以下代码可触发第二个 ThrowTypeError

new Promise() // Uncaught TypeError: Promise resolver undefined is not a function
复制代码

此时 newTarget 不等于 Undefined,不会触发第一个 ThrowTypeError。但调用 Promise 构造函数时没传参数 executor,触发了第二个 ThrowTypeError

executor 的类型是函数,在 JavaScript 的世界里,回调函数通常是异步调用,但 executor 是同步调用。在 Call(context, UnsafeCast(executor), Undefined, resolve, reject) 这一行,同步调用了 executor

console.log('同步执行开始')
new Promise((resolve, reject) => {
  resolve()
  console.log('executor 同步执行')
})

console.log('同步执行结束')
// 本段代码的打印顺序是:
// 同步执行开始
// executor 同步执行
// 同步执行结束
复制代码

Promise 构造函数接收的参数 executor,是被同步调用的

then

ECMAScript 规范[7]

PromisePrototypeThen

Promisethen 方法传入两个回调函数 onFulfilledonRejected,分别用于处理 fulfilledrejected 状态,并返回一个新的 Promise

JavaScript 层的 then 函数实际上是 V8 中的 PromisePrototypeThen 函数,源码如下[8]:

PromisePrototypeThen(js-implicit context: NativeContext, receiver: JSAny)(
    onFulfilled: JSAny, onRejected: JSAny): JSAny {
  const promise = Cast<JSPromise>(receiver) otherwise ThrowTypeError(
      MessageTemplate::kIncompatibleMethodReceiver, 'Promise.prototype.then',
      receiver);

  const promiseFun = UnsafeCast<JSFunction>(
      context[NativeContextSlot::PROMISE_FUNCTION_INDEX]);

  let resultPromiseOrCapability: JSPromise|PromiseCapability;
  let resultPromise: JSAny;
  label AllocateAndInit {
    // 创建一个新的 promise 用于当做本次 then 的调用结果返回
    //(上面有提到then的返回值是一个promise)
    const resultJSPromise = NewJSPromise(promise);
    resultPromiseOrCapability = resultJSPromise;
    resultPromise = resultJSPromise;
  }
  // onFulfilled 和 onRejected 是 then 接收的两个参数
  // 如果不传则默认值为 Undefined
  const onFulfilled = CastOrDefault<Callable>(onFulfilled, Undefined);
  const onRejected = CastOrDefault<Callable>(onRejected, Undefined);

  // 调用 PerformPromiseThenImpl 函数
  PerformPromiseThenImpl(
      promise, onFulfilled, onRejected, resultPromiseOrCapability);
  // 返回一个新的 Promise
  return resultPromise;
}
复制代码

PromisePrototypeThen 函数创建了一个新的 Promise 对象,获取 then 接收到的两个参数,调用 PerformPromiseThenImpl 完成大部分工作。这里有一点值得注意,then 方法返回的是一个新创建的 Promise

const myPromise2 = new Promise((resolve, reject) => {
  resolve('foo')
})

const myPromise3 = myPromise2.then(console.log)

// myPromise2 和 myPromise3 是两个不同的对象
// 有不同的状态和不同的处理函数
console.log(myPromise2 === myPromise3) // 打印 false
复制代码

then 方法返回的是一个新的 Promise

PerformPromiseThenImpl

ECMAScript 规范[9]

PerformPromiseThenImpl 有4个参数,因为 PerformPromiseThenImpl 是在调用 then 调用,所以它的前三个参数分别是被调用 then 方法的 Promise 对象,以及这个对象的两个处理函数 onFulfilledonRejected,最后一个参数为调用这个 then 返回的新 Promise 对象 resultPromiseOrCapability

PerformPromiseThenImpl 源码如下[10]:

transitioning macro PerformPromiseThenImpl(implicit context: Context)(
    promise: JSPromise, 
   onFulfilled: Callable|Undefined,
    onRejected: Callable|Undefined,
    resultPromiseOrCapability: JSPromise|PromiseCapability|Undefined): void {
  if (promise.Status() == PromiseState::kPending) {
    // pending 状态的分支
    // 如果当前 Promise 还是 pending 状态
    // 那么只需要将本次 then 绑定的处理函数存储起来即可
    const handlerContext = ExtractHandlerContext(onFulfilled, onRejected);
    // 拿到 Promise 的 reactions_or_result 字段
    const promiseReactions =
        UnsafeCast<(Zero | PromiseReaction)>(promise.reactions_or_result);
    // 考虑一个 Promise 可能会有多个 then 的情况
    // reaction 是个链表,每次绑定处理函数都在链表的头部插入
    // 存 Promise 的所有处理函数
    const reaction = NewPromiseReaction(
        handlerContext, promiseReactions, resultPromiseOrCapability,
        onFulfilled, onRejected);
    // reactions_or_result 可以存 Promise 的处理函数的链表,也可以存
    // Promise 的最终结果,因为现在 Promise 处于 pending 状态,
    // 所以存的是处理函数 reaction 构成的链表
    promise.reactions_or_result = reaction;
  } else {
    // fulfilled 和 rejected 状态的分支
    const reactionsOrResult = promise.reactions_or_result;
    let microtask: PromiseReactionJobTask;
    let handlerContext: Context;
    // fulfilled 分支
    if (promise.Status() == PromiseState::kFulfilled) {
      handlerContext = ExtractHandlerContext(onFulfilled, onRejected);
      // 生成 microtask 任务
      microtask = NewPromiseFulfillReactionJobTask(
          handlerContext, reactionsOrResult, onFulfilled,
          resultPromiseOrCapability);
    } else // rejected 分支
      deferred {
        assert(promise.Status() == PromiseState::kRejected);
        handlerContext = ExtractHandlerContext(onRejected, onFulfilled);
       // 生成 microtask 任务
        microtask = NewPromiseRejectReactionJobTask(
            handlerContext, reactionsOrResult, onRejected,
            resultPromiseOrCapability);
       // 如果当前 promise 还未绑定过处理函数
        if (!promise.HasHandler()) {
          // 规范中的 HostPromiseRejectionTracker(promise, "reject"),
          // 作用是产生一个检测的 microtask 任务,后面会单独介绍。
          runtime::PromiseRevokeReject(promise);
        }
      }
    // 即使调用 then 方法时 promise 已经处于 fulfilled 或 rejected 状态,
    // then 方法的 onFulfilled 或 onRejected 参数也不会立刻执行,
    // 而是进入 microtask 队列后执行
    EnqueueMicrotask(handlerContext, microtask);
  }
  promise.SetHasHandler();
}
复制代码

PerformPromiseThenImpl 函数的 pending 分支

PerformPromiseThenImpl 有三个分支,分别对应 Promise 的三个状态,当被调用 then 方法的 Promise 处于 pending 状态时则进入 pending分支。pending 分支调用 NewPromiseReaction 函数,在接收到的 onFulfilled 和 onRejected 参数的基础上,生成 PromiseReaction 对象,存储 Promise 的处理函数,并赋值给 JSPromisereactions_or_result 字段,然后调用 promise.SetHasHandler()has_handler 设置为 true(表示这个 Promise 对象已经绑定了处理函数)

考虑一个 Promise 可以会连续调用多个 then 的情况,比如:

const p = new Promise((resolve, reject) => {
  setTimeout(_ => {
    resolve('my code delay 2000 ms') 
  }, 2000)
})

p.then(result => {
  console.log('第 1 个 then')
})

p.then(result => {
  console.log('第 2 个 then')
})
复制代码

p 调用了两次 then 方法,每个 then 方法都会生成一个 PromiseReaction 对象。第一次调用 then 方法时生成对象 PromiseReaction1,此时 p 的 reactions_or_result 存的是 PromiseReaction1。

第二次调用 then 方法时生成对象 PromiseReaction2,调用 NewPromiseReaction 函数时,PromiseReaction2.next = PromiseReaction1,PromiseReaction1 变成了 PromiseReaction2 的下一个节点,最后 p 的 reactions_or_result 存的是 PromiseReaction2。PromiseReaction2 后进入 Promise 处理函数的链表,却是链表的头结点。NewPromiseReaction 函数源码如下[11]:

macro NewPromiseReaction(implicit context: Context)(
    handlerContext: Context, next: Zero|PromiseReaction,
    promiseOrCapability: JSPromise|PromiseCapability|Undefined,
    fulfillHandler: Callable|Undefined,
    rejectHandler: Callable|Undefined): PromiseReaction {
  const nativeContext = LoadNativeContext(handlerContext);
  return new PromiseReaction{
    map: PromiseReactionMapConstant(),
    next: next, // next 字段存的是链表中的下一个节点
    reject_handler: rejectHandler,// 失败处理函数
    fulfill_handler: fulfillHandler,// 成功处理函数
    promise_or_capability: promiseOrCapability,// 产生的新Promise对象
    continuation_preserved_embedder_data: nativeContext
        [NativeContextSlot::CONTINUATION_PRESERVED_EMBEDDER_DATA_INDEX]
  };
}
复制代码

在 p 处于 pending 状态时,p 的 reactions_or_result 字段示意如下图。

下图不是 microtask 队列,下图不是 microtask 队列,下图不是 microtask 队列。

reactions

PerformPromiseThenImpl 函数的 fulfilled 分支

fulfilled 分支逻辑则简单的多,处理的是当 Promise 处于 fulfilled 状态时,调用 then 方法的逻辑:

先调用 NewPromiseFulfillReactionJobTask 生成 microtask,然后 EnqueueMicrotask(handlerContext, microtask) 将刚才生成的 microtask 放入 microtask 队列,最后调用 promise.SetHasHandler()has_handler 设置为 true

new Promise((resolve, reject) => {
  resolve()
}).then(result => {
  console.log('进入 microtask 队列后执行')
})

console.log('同步执行结束')
// 本段代码的打印顺序是:
// 同步执行结束
// 进入 microtask 队列后执行
复制代码

尽管调用 then 方法时,Promise 已经处于 fulfilled 状态,但 then 方法的 onFulfilled 回调函数不会立即执行,而是进入 microtask 队列等待执行。

PerformPromiseThenImpl 函数的 rejected 分支

rejected 分支逻辑与 fulfilled 分支的逻辑大致相同,但是 rejected 分支中将 onRejected 处理函数加入 microtask 队列之前,会先判断当前 promise 是否已经存在处理函数,如果已经存在则会先调用 runtime::PromiseRevokeReject(promise),最后调用 promise.SetHasHandler()has_handler 设置为 true

if (!promise.HasHandler()) {
       runtime::PromiseRevokeReject(promise);
   }
复制代码

这里的runtime::PromiseRevokeReject(promise) 就是 ECMAScript 规范[12] 中的 HostPromiseRejectionTracker(promise, "handle")HostPromiseRejectionTracker 是一个抽象方法,这表示没有规定它的具体的逻辑。大致的作用是标记一下 promise 已经绑定了 rejected 状态的处理函数。不用疑惑为什么要这么做,后面会单独重点说。

注意 1 HostPromiseRejectionTracker 在两种情况下被调用:

当一个 promise 在没有任何处理程序的情况下被拒绝时,它的操作参数设置为“reject”。

当第一次将处理程序添加到被拒绝的 Promise 中时,将调用它并将其操作参数设置为“handle”。

引至 ——ECMAScript 规范[13](作者翻译)

小结

  1. 当一个 Promise 被调用 then 方法时,会创建一个新的 Promise 对象 resultPromise
  2. 然后根据当前 promise 的不同状态执行不同的逻辑

3 . 调用 promise.SetHasHandler() 将 Promise 的 has_handler 设置为 true,表示其被调用的 then 方法绑定了处理函数。 4 . 最后返回新的 Promise 对象。

再来回顾一下 reactions_or_result 的3个值状态(空、链表、promise的值):

当 promise 刚刚被创建时,reactions_or_result的值的空,

当promise的状态改变为 fulfilled/rejected 时,其值是调用对应 resolve(value)/reject(value) 函数传入的参数 value,也就是 promise 的值。

当 promise 为 pending 状态且被调用 then 后,reactions_or_result 为一个链表,链表的每一项存储的是调用 then 时传入的处理函数。

reslove

new Promise((resolve, reject) => {
  setTimeout(_ => resolve('fulfilled'), 5000)
}).then(value => {
  console.log(value)
}, reason => {
  console.log('rejected')
})
复制代码

上述代码 5s 后执行 resolve 函数,控制台打印 fulfilled。

FulfillPromise

ECMAScript 规范[14]

reslove(value) 就是规范中的 FulfillPromise(promise, value) 函数,他的作用是将一个 Promise 的状态由 pending 改变为 fulfilled,并且将这个 Promise 的所有处理函数都变成 microtask 加入到 microtask 队列中等待执行。

resolve 函数归根到底调用了 V8 的 FulfillPromise 函数,源码如下[15]:

// https://tc39.es/ecma262/#sec-fulfillpromise
transitioning builtin
FulfillPromise(implicit context: Context)(
    promise: JSPromise, value: JSAny): Undefined {
  // 断案当前promise状态一定是 pending,因为promise 的状态改变是不可逆的
  assert(promise.Status() == PromiseState::kPending);

  // 取 Promise 的处理函数,在这之前 Promise 的状态还是 pending
  // 所以 reactions_or_result 中存的是 reactions 链表,
  // reactions 节点中存储的是里函数
  const reactions =
      UnsafeCast<(Zero | PromiseReaction)>(promise.reactions_or_result);

  // Promise 需要修改为 fulfilled 状态,所以 reactions_or_result 存储的
  // 不再是处理函数,而是 Promise 的结果,也就是调用 resolve 时传入的参数
  promise.reactions_or_result = value;

  // 设置 Promise 的状态为 fulfilled
  promise.SetStatus(PromiseState::kFulfilled);

  // Promise 的处理函数,Promise 的结果都拿到了,开始正式处理
  TriggerPromiseReactions(reactions, value, kPromiseReactionFulfill);
  return Undefined;
}
复制代码

FulfillPromise 的逻辑是获取 Promise 的处理函数到 reactionsreactions 的类型是 PromiseReaction,是个链表,忘记的同学可以回看上面的那张链表图片;设置 promisereactions_or_resultvalue,这个 value 就是 JavaScript 层传给 resolve 的参数;调用 promise.SetStatus(PromiseState::kFulfilled) 设置 promise 的状态为 fulfilled,最后调用 TriggerPromiseReactions 来将 reactions 中的处理函数添加到 microtask 队列。

TriggerPromiseReactions

源码如下[16]:

// https://tc39.es/ecma262/#sec-triggerpromisereactions
transitioning macro TriggerPromiseReactions(implicit context: Context)(
    reactions: Zero|PromiseReaction, argument: JSAny,
    reactionType: constexpr PromiseReactionType): void {
  // We need to reverse the {reactions} here, since we record them on the
  // JSPromise in the reverse order.
  let current = reactions;
  let reversed: Zero|PromiseReaction = kZero;
  // 链表反转
  while (true) {
    typeswitch (current) {
      case (Zero): {
        break;
      }
      case (currentReaction: PromiseReaction): {
        current = currentReaction.next;
        currentReaction.next = reversed;
        reversed = currentReaction;
      }
    }
  }
  current = reversed;
  // 链表反转后,调用 MorphAndEnqueuePromiseReaction
  // 把链接中的每一项都进入 microtask 队列
  while (true) {
    typeswitch (current) {
      case (Zero): {
        break;
      }
      case (currentReaction: PromiseReaction): {
        current = currentReaction.next;
        MorphAndEnqueuePromiseReaction(currentReaction, argument, reactionType);
      }
    }
  }
}
复制代码

TriggerPromiseReactions 做了两件事:

MorphAndEnqueuePromiseReaction

MorphAndEnqueuePromiseReaction[17] 将 PromiseReaction 转为 microtask,最终插入 microtask 队列,morph 本身有转变/转化的意思,比如 Polymorphism (多态)。

MorphAndEnqueuePromiseReaction 接收 3 个参数,PromiseReaction 是前面提到的包装了 Promise 处理函数的链表对象,argument 是 resolve/reject 的参数,reactionType 表示 Promise 最终的状态,fulfilled 状态对应的值是 kPromiseReactionFulfill,rejected 状态对应的值是 kPromiseReactionReject。

MorphAndEnqueuePromiseReaction 的逻辑很简单,因为此时已经知道了 Promise 的最终状态,所以可以从 promiseReaction 对象得到 promiseReactionJobTask 对象,promiseReactionJobTask 的变量命名与 ECMAScript 规范相关描述一脉相承,其实就是传说中的 microtask。MorphAndEnqueuePromiseReaction 源码如下,仅保留了和本小节相关的内容。

transitioning macro MorphAndEnqueuePromiseReaction(implicit context: Context)(
    promiseReaction: PromiseReaction, argument: JSAny,
    reactionType: constexpr PromiseReactionType): void {
  let primaryHandler: Callable|Undefined;
  let secondaryHandler: Callable|Undefined;
  // 根据不同的 Promise 状态选取不同的回调执行
  if constexpr (reactionType == kPromiseReactionFulfill) {
    primaryHandler = promiseReaction.fulfill_handler;
    secondaryHandler = promiseReaction.reject_handler;
  } else {
    primaryHandler = promiseReaction.reject_handler;
    secondaryHandler = promiseReaction.fulfill_handler;
  }
  const handlerContext: Context =
      ExtractHandlerContext(primaryHandler, secondaryHandler);
  if constexpr (reactionType == kPromiseReactionFulfill) {// fulfilled 分支
    * UnsafeConstCast(& promiseReaction.map) =
        PromiseFulfillReactionJobTaskMapConstant();
    const promiseReactionJobTask =
        UnsafeCast<PromiseFulfillReactionJobTask>(promiseReaction);
    // argument 是 reject 的参数
    promiseReactionJobTask.argument = argument;
    // handler 是 JS 层面 then 方法的第二个参数,或 catch 方法的参数
    promiseReactionJobTask.context = handlerContext;
    // promiseReactionJobTask 就是那个工作中经常被反复提起的 microtask
    // EnqueueMicrotask 将 microtask 插入 microtask 队列
    EnqueueMicrotask(handlerContext, promiseReactionJobTask);
    // 删除
  } else {// rejected 分支
      // 逻辑与 fulfilled 分支前面一致
    * UnsafeConstCast(& promiseReaction.map) =
        PromiseRejectReactionJobTaskMapConstant();
    const promiseReactionJobTask =
        UnsafeCast<PromiseRejectReactionJobTask>(promiseReaction);
    promiseReactionJobTask.argument = argument;
    promiseReactionJobTask.context = handlerContext;
    promiseReactionJobTask.handler = primaryHandler;
    EnqueueMicrotask(handlerContext, promiseReactionJobTask);
  }
}
复制代码

MorphAndEnqueuePromiseReaction 的功能很简单,就是根据 Promise 的状态选取 onFulfilled 还是 onRejected 放到 microtask 队列准备执行。这里走的是 fulfilled 分支,所以选取的是 onFulfilled。

const myPromise4 = new Promise((resolve, reject) => {
  setTimeout(_ => {
    resolve('my code delay 1000') 
  }, 1000)
})

myPromise4.then(result => {
  console.log('第 1 个 then')
})

myPromise4.then(result => {
  console.log('第 2 个 then')
})
// 打印顺序:
// 第 1 个 then
// 第 2 个 then
// 如果把 TriggerPromiseReactions 中链表反转的代码注释掉,打印顺序为
// 第 2 个 then
// 第 1 个 then
复制代码

小结

resolve 只会处理状态为 pending 的 Promise,会将 Promise 的 reactions_or_result 设置为传入的 value,用来作为 Promise 的值,并且会将 Promise 的状态修改为 fulfilled。

因为 promise 在使用 then 收集依赖时是将最新的依赖存放到链表头部,所以还需要先对链表进行反转,然后将其挨个放入 microtask 队列中等待执行

resolve 的主要工作是遍历上节调用 then 方法时收集到的依赖,放入 microtask 队列中等待执行。

reject

reject 与 reslove 没什么太大差别

ECMAScript 规范[18]

new Promise((resolve, reject) => {
  setTimeout(_ => reject('rejected'), 5000)
}).then(_ => {
  console.log('fulfilled')
}, reason => {
  console.log(reason)
})
复制代码

上述代码 5s 后执行 reject 函数,控制台打印 rejected。

RejectPromise

ECMAScript 规范[19]

reject(season) 函数调用了 V8 的 RejectPromise(promise, season) 函数,源码如下[20] :

// https://tc39.es/ecma262/#sec-rejectpromise
transitioning builtin
RejectPromise(implicit context: Context)(
    promise: JSPromise, reason: JSAny, debugEvent: Boolean): JSAny {

  // 如果当前 Promise 没有绑定处理函数,
  // 则会调用 runtime::RejectPromise
  if (IsPromiseHookEnabledOrDebugIsActiveOrHasAsyncEventDelegate() ||
      !promise.HasHandler()) {
    return runtime::RejectPromise(promise, reason, debugEvent);
  }

  // 取出 Promise 的处理对象 PromiseReaction
  const reactions =
      UnsafeCast<(Zero | PromiseReaction)>(promise.reactions_or_result);
  // 这里的 reason 就是 reject 函数的参数
  promise.reactions_or_result = reason;
  // 设置 Promise 的状态为 rejected
  promise.SetStatus(PromiseState::kRejected);
  // 将 Promise 的处理函数都添加到 microtask 队列
  TriggerPromiseReactions(reactions, reason, kPromiseReactionReject);
  return Undefined;
}
复制代码

HostPromiseRejectionTracker

与 ReslovePromise 相比,RejectPromise 中多出一个判断 Promsie 是否绑定了处理函数的判断,如果没有绑定处理函数则会先执行 runtime::RejectPromise(promise, reason, debugEvent),这是其实是 ECMAScript 规范中的 HostPromiseRejectionTracker(promise, "reject") ,这已经是第二次提到 HostPromiseRejectionTracker了。

PerformPromiseThenImpl 函数的 rejected 分支 处有提到过一次。

在 ECMAScript 规范中 HostPromiseRejectionTracker 是一个抽象方法,他甚至没有明确的执行过程,好在规范中描述了他的作用。

HostPromiseRejectionTracker 用于跟踪 Promise 的 rejected,例如全局的 rejectionHandled 事件就是由它实现。

注1 HostPromiseRejectionTracker 在两种情况下被调用:

当一个 Promise 在没有任何处理函数的情况下被调用 reject 时,调用它并且第二个参数传递 “reject”。

当第一次为 rejected 状态的 Promise 绑定处理函数时,调用它并且第二个参数传递 “handle”。

所以在这里,当传递 “handle” 就相对于为这个 Promise 对象标记为已经绑定了处理函数,当传递 “reject” 相对于标记这个 Promise 对象还没有处理函数。

我们先来看几段代码看看他的实际作用

当我们调用一个 Promise 的状态为 reject 且未为其绑定 onRejected 的处理函数时, JavaScript会抛出错误

const myPromise1 = new Promise((resolve, reject) => {
    reject()
})
// 报错
复制代码

并且检测是否绑定处理函数是一个异步的过程

console.log(1);
const myPromise1 = new Promise((resolve, reject) => {
    reject()
})
console.log(2);
// 1
// 2
// 报错
复制代码

我们可以为其绑定一个 onRejected 处理函数来解决我们报错

const myPromise1 = new Promise((resolve, reject) => {
    reject()
})// 得到一个 rejected 状态的 Promise
myPromise1.then(undefined, console.log)
复制代码

你一定会疑惑,Promise 是在何时检测它是否绑定了 onRejected 处理函数,如何检测的?

这就是 HostPromiseRejectionTracker 的作用,在 ECMAScript 规范中还提到,当调用 HostPromiseRejectionTracker(promise, 'reject') 时, 如果 promsie 不存在处理函数,则会为其设置一个处理函数。

回到上面的逻辑,当一个 Promise 的 reject 函数被调用时, 如果没有 onRejected 处理函数,则会调用 runtime::RejectPromise 来为其添加一个处理函数,然后后面会调用 TriggerPromiseReactions 将这个处理函数加入到 microtask 队列,这个处理函数时做的事情就是再次检测 Promise 是否被绑定了新的 onRejected(也就是有没有在此期间执行了 HostPromiseRejectionTracker(promise, 'handle') ),如果没有则抛出错误,如果有则什么也不发生。

所以在对一个 reject 状态的 Promise 调用 then 方法时需要对其调用 runtime::PromiseRevokeReject(promise) 来表示这个 Promise 绑定了新的 onRejected,防止错误被抛出。

所以你必须要赶在这个检测的 microtask 执行之前绑定处理函数才能防止这个错误的抛出。

const myPromise1 = new Promise((resolve, reject) => {
    // 同步执行
    reject()
    // 会向 microtask 队列中插入一个检查 myPromise1 
    // 是否绑定了新的 onRejected 处理函数的 microtask
})

// macrotask
setTimeout(() => {
   // 此时 microtask 已经执行,错误已经抛出,来不及了
    myPromise1.then(undefined, console.log)
}, 0)
复制代码

小结

reject 和 resolve 的逻辑基本相同,分为 4 步:

catch

new Promise((resolve, reject) => {
    setTimeout(reject, 2000)
}).catch(_ => {
    console.log('rejected')
})
复制代码

PromisePrototypeCatch

以上面代码为例,当 catch 方法执行时,调用了 V8 的 PromisePrototypeCatch[21] 方法,源码如下:

transitioning javascript builtin
PromisePrototypeCatch(
    js-implicit context: Context, receiver: JSAny)(onRejected: JSAny): JSAny {
  const nativeContext = LoadNativeContext(context);
  return UnsafeCast<JSAny>(
      InvokeThen(nativeContext, receiver, Undefined, onRejected));
}
复制代码

PromisePrototypeCatch 的源码确实只有就这几行,除了调用 InvokeThen 方法再无其它 。

InvokeThen

从名字可以推测出,InvokeThen 调用的是 Promise 的 then 方法,InvokeThen[22] 源码如下:

transitioning
macro InvokeThen<F: type>(implicit context: Context)(
    nativeContext: NativeContext, receiver: JSAny, arg1: JSAny, arg2: JSAny,
    callFunctor: F): JSAny {
  if (!Is<Smi>(receiver) &&
      IsPromiseThenLookupChainIntact(
          nativeContext, UnsafeCast<HeapObject>(receiver).map)) {
    const then =
        UnsafeCast<JSAny>(nativeContext[NativeContextSlot::PROMISE_THEN_INDEX]);
    // 重点在下面一行,调用 then 方法并返回,两个分支都一样
    return callFunctor.Call(nativeContext, then, receiver, arg1, arg2);
  } else
    deferred {
      const then = UnsafeCast<JSAny>(GetProperty(receiver, kThenString));
      // 重点在下面一行,调用 then 方法并返回,两个分支都一样
      return callFunctor.Call(nativeContext, then, receiver, arg1, arg2);
    }
}
复制代码

InvokeThen 方法有 if/else 两个分支,两个分支的逻辑差不多,本小节的 JS 示例代码走的是 if 分支。先是拿到 V8 原生的 then 方法,然后通过 callFunctor.Call(nativeContext, then, receiver, arg1, arg2) 调用 then 方法。then 方法之前有介绍,这里不再赘述。

既然 catch 方法底层调用了 then 方法,那么 catch 方法也有和 then 方法一样的返回值,catch 方法可以继续抛出异常,可以继续链式调用。

new Promise((resolve, reject) => {
    setTimeout(reject, 2000)
}).catch(_ => {
    throw 'rejected'
}).catch(_ => {
    console.log('last catch')
})
复制代码

上面的代码第 2 个 catch 捕获第 1 个 catch 抛出的异常,最后打印 last catch。

小结

catch 方法通过底层调用 then 方法来实现 假如 obj 是一个 Promise 对象,JS 层面 obj.catch(onRejected) 等价于 obj.then(undefined, onRejected)

then 的链式调用与 microtask 队列

Promise.resolve('123')
    .then(() => {throw new Error('456')})
    .then(_ => {
        console.log('shouldnot be here')
    })
    .catch((e) => console.log(e))
    .then((data) => console.log(data));
复制代码

以上代码运行后,打印 Error: 456 和 undefined。为了便于叙述,将 then 的链式调用写法改为啰嗦写法。

const p0 = Promise.resolve('123')
const p1 = p0.then(() => {throw new Error('456')})
const p2 = p1.then(_ => {
    console.log('shouldnot be here')
})
const p3 = p2.catch((e) => console.log(e))
const p4 = p3.then((data) => console.log(data));
复制代码

then 方法返回新的 Promise,所以 p0、p1、p2、p3 和 p4 这 5 个 Promise 互不相等。

当一个 Promise 处于 rejected 状态时,如果找不到 onRejected 处理函数则会将 rejected 的状态和其值往下传递,直到找到为止。(resolve也是一样),这个过程后面会介绍

catch 方法的作用就是绑定 onRejected 函数

microtask 的执行

所有同步代码执行完毕,开始执行取 microtask 队列中的 microtask 执行,核心方法是 MicrotaskQueueBuiltinsAssembler::RunSingleMicrotask[23] ,由于 microtask 的类型由很多种,所以 RunSingleMicrotask 的分支有许多。这里就不列出代码了。

PromiseReactionJob

在执行 microtask 的过程中,MicrotaskQueueBuiltinsAssembler::RunSingleMicrotask 会调用 PromiseReactionJob[24],源码如下:

transitioning
macro PromiseReactionJob(
    context: Context, argument: JSAny, handler: Callable|Undefined,
    promiseOrCapability: JSPromise|PromiseCapability|Undefined,
    reactionType: constexpr PromiseReactionType): JSAny {
  if (handler == Undefined) {
    // 没有处理函数的 case,透传上一个 Promise 的 argument
    if constexpr (reactionType == kPromiseReactionFulfill) {
      // 基本类同 JS 层的 resolve
      return FuflfillPromiseReactionJob(
          context, promiseOrCapability, argument, reactionType);
    } else {
      // 基本类同 JS 层的 reject
      return RejectPromiseReactionJob(
          context, promiseOrCapability, argument, reactionType);
    }
  } else {
    try {
      // 试图调用 Promise 处理函数,相当于 handler(argument)
      const result =
          Call(context, UnsafeCast<Callable>(handler), Undefined, argument);
        // 基本类同 JS 层的 resolve
        return FuflfillPromiseReactionJob(
            context, promiseOrCapability, result, reactionType);
    } catch (e) {
      // 基本类同 JS 层的 reject,当执行 handler 是抛出异常会触发
      return RejectPromiseReactionJob(
          context, promiseOrCapability, e, reactionType);
    }
  }
}
复制代码

PromiseReactionJob 中会判断当前任务是否存在需要执行的处理函数,如果不存在则直接将上一个 Promise 的值作为参数调用 FuflfillPromiseReactionJob ,如果存在则执行这个处理函数,将执行结果当做参数调用 FuflfillPromiseReactionJob。

也就是说,只要一个 Promise 的 onFulfilled 或者 onRejected 在执行过程中只要没有抛出异常,这个 Promise 就会执行 FuflfillPromiseReactionJob 将状态修改为 fulfilled。如果抛出异常则执行 RejectPromiseReactionJob。

let p0 = new Promise((resolve, reject) => {
    reject(123)
})
// p1 的状态为 reject

let p1 = p0.then(value => {
    console.log(value);
}, reason => {
    console.log(reason);
   return 2
})
// 将 reason => {console.log(reason)} 加入 microtask 队列

p1.then(_ => {
    console.log('p1');
})
// 为 p1 添加 PromiseReaction

// 取  microtask 队列 第一个执行,
// handler 为 reason => {console.log(reason)},

// 成功执行 handler, 所以调用 FuflfillPromiseReactionJob 
// 执行 p1 的 resolve
复制代码

注意:FuflfillPromiseReactionJob 做的事情很多,执行 resolve 只是其中的一个分支

我们来看看 FuflfillPromiseReactionJob 具体做了哪些事情。

FuflfillPromiseReactionJob

源码如下:

transitioning
macro FuflfillPromiseReactionJob(
    context: Context,
    promiseOrCapability: JSPromise|PromiseCapability|Undefined, result: JSAny,
    reactionType: constexpr PromiseReactionType): JSAny {
  typeswitch (promiseOrCapability) {
    case (promise: JSPromise): {
      // 调用 ResolvePromise,也就是 promise 的 resolve(result)
      return ResolvePromise(context, promise, result);
    }
    case (Undefined): {
      return Undefined;
    }
    case (capability: PromiseCapability): {
      const resolve = UnsafeCast<Callable>(capability.resolve);
      try {
        return Call(context, resolve, Undefined, result);
      } catch (e) {
        return RejectPromiseReactionJob(
            context, promiseOrCapability, e, reactionType);
      }
    }
  }
}
复制代码

FuflfillPromiseReactionJob 有3个分支,这里走的是第一个分支,调用 ResolvePromise[25],这个方法很重要,他是规范中的 Promise Resolve Functions[26],他的作用是同步当前处理函数的结果(值和状态)给其产生的promsie。promiseOrCapability。

上面例子中 promiseOrCapability 就是 p1, 值是 2

ResolvePromise

这是一个很重要的方法,基本上每一个 Promise 的状态需要变成 fulfilled 都会调用它,它的逻辑也产生了许多 PromiseA+ 中没有的特性。下面的代码我删除了不重要的部分

// https://tc39.es/ecma262/#sec-promise-resolve-functions
transitioning builtin
ResolvePromise(implicit context: Context)(
    promise: JSPromise, resolution: JSAny): JSAny {
 // 删
  let then: Object = Undefined;
  try {
    // 调用 FulfillPromise
    const heapResolution = UnsafeCast<HeapObject>(resolution);
    const resolutionMap = heapResolution.map;
    if (!IsJSReceiverMap(resolutionMap)) {
      return FulfillPromise(promise, resolution);
    }
    // 删
    const promisePrototype =
        *NativeContextSlot(ContextSlot::PROMISE_PROTOTYPE_INDEX);
    // 重要:如果 resolution 是一个 Promise 对象
    if (resolutionMap.prototype == promisePrototype) {
      then = *NativeContextSlot(ContextSlot::PROMISE_THEN_INDEX);
      static_assert(nativeContext == LoadNativeContext(context));
      goto Enqueue;
    }
    goto Slow;
  } label Slow deferred {
    // 如果 resolution 是一个包含then属性的对象,会来到这
    try {
      // 获取 then 属性
      then = GetProperty(resolution, kThenString);
    } catch (e) {
      return RejectPromise(promise, e, False);
    }
    // 如果 then 属性不是一个可执行的方法
    if (!Is<Callable>(then)) {
      // 将执行结果同步到 promise
      return FulfillPromise(promise, resolution);
    }
    goto Enqueue;
  } label Enqueue {
    // 重要:如果 执行结果是一个 Promise 对象
    // 或者包含可执行的 then 方法的对象,会来到这
    const task = NewPromiseResolveThenableJobTask(
        promise, UnsafeCast<JSReceiver>(resolution),
        UnsafeCast<Callable>(then));
    return EnqueueMicrotask(task.context, task);
  }
}
复制代码

ResolvePromise 方法中有几个很重要的逻辑,一个是调用 FulfillPromise,这个在resolve的时候已经介绍过了,作用是修改 promise 的状态为 fulfilled 并为其设置值,然后将 promise 的处理函数推到微任务队列。

let p0 = Promise.resolve()
let p1 = p0.then(() => {
  return 1;
})

p1.then(console.log)

// p0 then 中 onFulfilled 回调进入队列
// PromiseReactionJob 中调用 p0 的 onFulfilled ,得到结果为1
// 调用 FuflfillPromiseReactionJob ,然后调用 ResolvePromise
// ResolvePromise 做如下操作
// 将 p1 变成 fulfilled, 并将 p1 的处理函数 console.log 加到队列,参数为 1
// p1 的 onFulfilled 出队列执行,输出 1
复制代码

还有一种情况就是 当 resolution 的值是一个 Promise 对象或者是一个包含 then 方法的对象时。会调用 NewPromiseResolveThenableJobTask 生成一个 microtask,然后将其加入 microtask 队列中。

let p0 = Promise.resolve()
// 两种特殊情况
let p1 = p0.then(() => {
  return Promise.resolve(1);// 返回值是 Promise 对象
})
let p2 = p0.then(() => {
  return {then(resolve, reject){resolve(1)};// 返回值包含 then 方法
})

p1.then(console.log)
复制代码

NewPromiseResolveThenableJobTask

NewPromiseResolveThenableJobTask 的目的是调用 resolution 的 then 方法,在回调函数中同步状态给 promise。这可能不是很好理解,我把他转化为js来大致就是这样的。

microtask(() => {
  resolution.then((value) => {
    ReslovePromise(promise, value) 
  })
})
复制代码

这个任务中会调用 resolution.then ,然后同步到 promsie。但是这个整体的过程需要加入 microtask 队列中等待运行,当这个任务运行时,如果 resolution 也是一个 Promise 的话,则 (value) => {ReslovePromise(promise, value) } 又会被作为一个 microtask 加入 microtask 队列中等待运行。

你可以会疑惑为什么要这样做?为什么不同步调用 resolution.then((value) => {ReslovePromise(promise, value) }),而是把他封装为一个 microtask 呢?我一开始也感到疑惑,好在规范中给出了一个原因。

注意: 此作业使用提供的 thenable 及其 then 方法来解决给定的 Promise。此过程必须作为作业进行,以确保在对任何周围代码的评估完成后对 then 方法进行评估。

引至 ECMAScript NewPromiseResolveThenableJobTask 规范[27](作者翻译)

什么是 thenable:

Javascript 为了识别 Promise 产生的一个概念,简单来说就是所有包含 then 方法的对象都是 thenable。

『以确保在对任何周围代码的评估完成后对 then 方法进行评估』指的是什么呢?我唯一能想到的就是下面这种情况。

const p1 = new Promise((resolve, reject) => {
    const p2 = Promise.resolve().then(() => {
        resolve({
            then: (resolve, reject) => resolve(1)
        });
        const p3 = Promise.resolve().then(() => console.log(2));
    });
}).then(v => console.log(v));
// 2 1
复制代码

上面 p2 的 onFulfilled回调 会先进入 microtask 队列,等待其执行时 调用 p1 的 resolve,但是参数是一个包含 then 方法的对象。这时 p1 不会立即改变为 fulfilled,而是创建一个 microtask 来执行这个then方法,然后将 p2的 onFulfilled 加入 microtask 队列。这时 microtask 队列中有两个 microtask,一个是执行 resolve 返回值中的 then函数,另一个则是 p3的 onFulfilled 函数。

然后取出第一个 microtask 执行(取出后 microtask 队列中只剩下 p3的 onFulfilled),执行后 p1 的状态变为 fulfilled,然后 p1 的 onFulfilled 进入队列。后面可想而知是相继输出 2和1(因为 p1 的 onFulfilled 函数在 p3 的 onFulfilled 函数之后进入 microtask 队列)。

如果没有将 NewPromiseResolveThenableJobTask 作为一个 microtask。也就变成了 p2.then 中的回调执行时同步触发 resolve 参数中的 then 方法,fulfilled 的状态会立即同步到 p1,这时 p1 的 onFulfilled 就会先进入 microtask,导致结果变为 12。这样的执行结果可以会让JavaScript开发者感到疑惑。

所以 ECMAScript 将其作为一个异步任务来执行。

似乎 返回 Promsie 对象会产生两个 microtask 似乎会更让人感到疑惑。

RejectPromiseReactionJob

PromiseReactionJob 中如果处理函数 handler 执行时抛出异常则会执行 RejectPromiseReactionJob,也就是下面这种情况

let p0 = Promise.resolve()
let p1 = p0.then(() => {
    throw 'error'; // handler 执行时出错
})
复制代码

这是会调用 RejectPromiseReactionJob,其源码如下

macro RejectPromiseReactionJob(
    context: Context,
    promiseOrCapability: JSPromise|PromiseCapability|Undefined, reason: JSAny,
    reactionType: constexpr PromiseReactionType): JSAny {
  if constexpr (reactionType == kPromiseReactionReject) {
    typeswitch (promiseOrCapability) {
      case (promise: JSPromise): {
// promiseOrCapability 就是 p1,是一个 Promise 对象
// 执行 RejectPromise,调用 p1 的 reject 方法
        return RejectPromise(promise, reason, False);
      }
      case (Undefined): {
        return Undefined;
      }
      case (capability: PromiseCapability): {
        const reject = UnsafeCast<Callable>(capability.reject);
        return Call(context, reject, Undefined, reason);
      }
    }
  } else {
    StaticAssert(reactionType == kPromiseReactionFulfill);
    return PromiseRejectReactionJob(reason, Undefined, promiseOrCapability);
  }
}
复制代码

RejectPromiseReactionJob 与 FuflfillPromiseReactionJob 是类似的,就是调用 RejectPromise 来调用 Promsie 的 reject 方法,这个在上面 reject 的地方介绍过了。

PromiseReactionJob的handler == Undefined分支

PromiseReactionJob 中还有一个 handler == Undefined 的分支也很重要,当一个 task 中的 handler 为 undefined时会进入这个分支,为了方便阅读,这里再贴一下代码

transitioning
macro PromiseReactionJob(
    context: Context, argument: JSAny, handler: Callable|Undefined,
    promiseOrCapability: JSPromise|PromiseCapability|Undefined,
    reactionType: constexpr PromiseReactionType): JSAny {
  if (handler == Undefined) {
    // 没有处理函数的 case,透传上一个 Promise 的 argument
    if constexpr (reactionType == kPromiseReactionFulfill) {
      // 基本类同 JS 层的 resolve
      return FuflfillPromiseReactionJob(
          context, promiseOrCapability, argument, reactionType);
    } else {
      // 基本类同 JS 层的 reject
      return RejectPromiseReactionJob(
          context, promiseOrCapability, argument, reactionType);
    }
  } else {
    // 删除
  }
}
复制代码

进入分支后会直接获取上一个 Promise 对象的 value 和 状态 同步到当前 promise 来,我们来通过一段js了解他

let p0 = new Promise((resolve, reject) => {
    reject(123)
})
// p0 的状态为 rejected

let p1 = p0.then(_ => {console.log('p0 onFulfilled')})
// p0 的 onRejected 作为 handler 进入 microtask 队列
// 但是因为 then 没有传递第二个参数
// 所以 onRejected 是 undefined,那么 handler 也是 undefined

let p2 = p1.then(_ => {console.log('p1 onFulfilled')})
/*
为p1绑定 
PromiseReaction{
  onFulfilled:_ => {console.log('p1 onFulfilled')}, 
  onRejected:undefined
}
*/
let p3 = p2.then(_ => {console.log('p2 onFulfilled')}, _ => {console.log('p2 onRejected')})
/*
为p2绑定 
PromiseReaction{
  onFulfilled:_ => {console.log('p2 onFulfilled')}, 
  onRejected:_ => {console.log('p2 onRejected')
}
*/
let p4 = p3.then(_ => {console.log('p3 onFulfilled')}, _ => {console.log('p3 onRejected')})
/*
为p3绑定 
PromiseReaction{
  onFulfilled:_ => {console.log('p3 onFulfilled')}, 
  onRejected:_ => {console.log('p3 onRejected')
}
*/

//p2 onRejected
//p3 onFulfilled
复制代码

同步代码执行完毕后(执行过程大致如注释),开启取 microtask 执行,此时 microtask 队列中只有一个 handler 为 undefined 的任务。进入 PromiseReactionJob 的 handler == Undefined 分支。

因为此时 p0 状态为 rejected,所以执行 RejectPromiseReactionJob(context, promiseOrCapability, argument, reactionType),其中 promiseOrCapability 就是p1, argument 就是 p0 的值 123,reactionType 为 rejected。

执行后 p0 的状态也变为 reactionType 也就是 rejected,p1 的值为 argument(相当于吧p0的状态和值都转移到了p1)。

然后执行 p1 的 reject 函数(FulfillPromise(p1, 123)),会吧 p1 绑定的 PromiseReaction 链表中的 onRejected(还是undefined) 当做 handler 进入microtask 队列(因为 p1 的状态是 rejected,所以是onRejected)

同样还是取 microtask 任务执行,handler 还是 undefined,后面就和上面一样,把状态 rejected 和值 123 继续同步给 p2,..........

再次取 microtask 执行,因为 p2 绑定了 onRejected 函数,所以 handler 不是 undefined,则不走 handler == Undefined 分支,另一个分支的逻辑刚刚已经描述过了。大概就是执行 onRejected(123),然后将其结果设置到 p3 的value,p3 变为 fulfilled 状态。

输出 p2 onRejected

因为 onRejected(123) 的返回值是 undefined,所以 p3 变为 fulfilled 状态,且值为 undefined

后面还是一样的,但是 handler 就是 onFulfilled 了,因为 p3 的状态是 fulfilled嘛,这里就相当于 onFulfilled(undefined)(因为 p3 的值的 undefined)。

输出 p3 onFulfilled

而后 p4 的状态也变成了 fulfilled,值也是 undefined,因为 p3 的 onFulfilled 返回值是 undefined

然后 p4 的 onFulfilled 变成 handler 队列,因为 p4 没有调用 then 绑定过 onFulfilled 处理函数。但是因为没有调用 then 方法,所以也没有产生新的 Promsie 对象,这次在执行 FuflfillPromiseReactionJob 方法的时候进入 promiseOrCapability 为 Undefined 分支就结束了

至此所有相关的任务全部执行完成

如果上面你看懂了,那么下面这段代码我想你也应该能知道结果

Promise.resolve('123')
    .then(() => {throw new Error('456')})
    .then(_ => {
        console.log('shouldnot be here')
    })
    .catch((e) => console.log(e))
    .then((data) => console.log(data));
复制代码

catch(onRejected) 的本质是 then(undefined, onRejected)

这就是 Promise 的 rejected 传递机制,不断向下传递直到遇见 onRejected 处理函数为止

Promise 的几个高难度题目

题目1

Promise.resolve().then(() => {
    console.log(0);
    return Promise.resolve(4);
}).then((res) => {
    console.log(res)
})

Promise.resolve().then(() => {
    console.log(1);
}).then(() => {
    console.log(2);
}).then(() => {
    console.log(3);
}).then(() => {
    console.log(5);
}).then(() => {
    console.log(6);
})
// 0 1 2 3 4 5 6
复制代码

主要考察 当 Promise 的值是 promsie 对象时会如何处理,在本文 的 then 的链式调用与 microtask 队列> ResolvePromise 目录末尾处开始介绍

关键字:thenableNewPromiseResolveThenableJobTask

题解

为了方便描述,我们将上面的代码转化为下面这样

let p1 = Promise.resolve()
let p2 = p1.then(() => {
    console.log(0);
    let p3 = Promise.resolve(4)
    return p3;
})
let p4 = p2.then((res) => {
    console.log(res)
})

let p5 = Promise.resolve()
let p6 = p5.then(() => {
    console.log(1);
})
let p7 = p6.then(() => {
    console.log(2);
})
let p8 = p7.then(() => {
    console.log(3);
})
let p9 = p8.then(() => {
    console.log(5);
})
let p10 = p9.then(() => {
    console.log(6);
})
复制代码

先执行所有的同步代码,执行过程如下面的注释

let p1 = Promise.resolve()
// 1. p1 的状态为 fulfilled

let p2 = p1.then(() => {
    console.log(0);
    let p3 = Promise.resolve(4)
    return p3;
})
// 2. 因为 p1 的状态已经是 fulfilled,所以调用 then 后立即将 onFulfilled 放入 microtask 队列
// 此时 microtask 只有p1的 onFulfilled: [p1.onFulfilled]

let p4 = p2.then((res) => {
    console.log(res)
})
// 3. p2的状态还是 pending,所以调用 then 后是为 p2 收集依赖,此时 p2 的 reactions 如下
/*{
    onFulfilled: (res) => {console.log(res)},
    onRejected: undefined
}*/


let p5 = Promise.resolve()
// 4. p5 的状态为 fulfilled

let p6 = p5.then(() => {
    console.log(1);
})
// 5. 同第2步,将 onFulfilled 加入 microtask 队列
// 此时 microtask 是: [p1.onFulfilled, p5.onFulfilled]

let p7 = p6.then(() => {
    console.log(2);
})
// 6. 同第3步,是给 p6 添加 reactions

let p8 = p7.then(() => {
    console.log(3);
})
// 7. 同上,是给 p7 添加 reactions

let p9 = p8.then(() => {
    console.log(5);
})
// 8. 同上,是给 p8 添加 reactions

let p10 = p9.then(() => {
    console.log(6);
})
// 9. 同上,是给 p9 添加 reactions
复制代码

10 . 当同步代码执行完成后,microtask 队列只有

[p1.onFulfilled, p5.onFulfilled]
复制代码

11 . 然后取出 p1.onFulfilled 来执行,此时输出 0,但是发现 p1.onFulfilled 返回值的 p3 是一个 Promise 对象。所以会执行 ResolvePromise 的 Enqueue 代码块,里面会调用 NewPromiseResolveThenableJobTask 产生一个微任务,这个微任务的要做的事情上面已经介绍过,大致就是下面这样

let promiseResolveThenableJobTask = () => {
    p3.then((value) => { 
        ReslovePromise(p2, value) 
    })
}
复制代码

然后将其加入 microtask 队列, 这时 microtask 队列就变成了 :

[p5.onFulfilled, promiseResolveThenableJobTask]
复制代码

12 . 继续取出 p5.onFulfilled 执行,此时输出 1,因为 p5.onFulfilled 返回值是 undefined,所以就将 undefined 作为 p6 的值,然后将 p6 的状态变为 fulfilled。

因为 p6 的状态被改变,所以它的 reactions 也会加入 microtask 队列,这时 microtask 队列就变成这样:

[promiseResolveThenableJobTask,p6.onFulfilled]
复制代码

13 . 同样是取 promiseResolveThenableJobTask 执行,因为 promiseResolveThenableJobTask 的内容是下面这样

let promiseResolveThenableJobTask = () => {
    p3.then((value) => { 
        ReslovePromise(p2, value) // ReslovePromise 的作用上面有介绍
    })
}
复制代码

所以执行 promiseResolveThenableJobTask 时就相当于执行了 p3.then((value) => {ReslovePromise(p2, value)})

因为 p3 的状态是 fulfilled ,所以会将其 onFulfilled 加入 microtask 队列(参数就是 p2 的值 undefined),这时 microtask 队列就变成这样:

[p6.onFulfilled,p3.onFulfilled]
复制代码

14 . 同样是取 p6.onFulfilled 执行,然后输出 2 并将其返回值 undefined 设置为 p7 的值,并将 p7 变为 fulfilled 状态,所以 p7 的 reactions 也会加入 microtask 队列,这时 microtask 队列就变成这样:

[p3.onFulfilled,p7.onFulfilled]
复制代码

15 . p3.onFulfilled 出队执行,p3.onFulfilled 是 (value) => {ReslovePromise(p2, value)}, 参数 value 是 undefined,所以此时就执行 ReslovePromise(p2, undefined),这就相当于调用了 p2 的 resolve。

所以此时 p2 的 值变为 undefined, 状态为变 fulfilled,然后将其 reactions 挨个加入 microtask 队列,这时 microtask 队列就变成这样:

[p7.onFulfilled,p2.onFulfilled]
复制代码

16 . p7.onFulfilled 出队列执行,输出 3,p8 状态变为 fulfille,值变为 undefined,然后 p8.onFulfilled 加入队列

[p2.onFulfilled,p8.onFulfilled]
复制代码

17 . p2.onFulfilled 出队列执行,输出 4,因为 p2 没有被在此调用 then 方法,所以就没有产生下一个 Promise 对象,所以也就没有后序了。

[p8.onFulfilled]
复制代码

18 . 后面就不用说了

题目2

Promise.resolve().then(() => {
    console.log(0);
    return {then(resolve){resolve(4)}};
}).then((res) => {
    console.log(res)
})

Promise.resolve().then(() => {
    console.log(1);
}).then(() => {
    console.log(2);
}).then(() => {
    console.log(3);
}).then(() => {
    console.log(5);
}).then(() => {
    console.log(6);
})
// 0 1 2 4 3 5 6
复制代码

与上题知识点一致,考察的是 Promise 的值是一个包含 then 方法的对象时发生的逻辑

关键字:thenableNewPromiseResolveThenableJobTask

题目3

const p1 = new Promise((resolve, reject) => {
    reject(0)
})
console.log(1);
setTimeout(() => {
    p1.then(undefined, console.log)
}, 0)
console.log(2);
// 1
// 2
// 输出报错 UnhandledPromiseRejection: This error originated either

const p1 = new Promise((resolve, reject) => {
    reject(0)
})
console.log(1);
p1.then(undefined, console.log)
console.log(2);
// 1
// 2
// 0
复制代码

为什么第一种方式会报错?

考察的是规范中的 HostPromiseRejectionTracker,当一个没有绑定处理函数的 Promsie 被调用 reject 则会创建一个 微任务来再次检测这个 Promise 是否存在处理函数,如果此时还不存在则输出报错,setTimeout回调执行在微任务之后。

本文 reject > HostPromiseRejectionTracker 目录处有详细介绍。

题目四

为什么 async1 end 输出在 promise3 之后?

async function async1() { 
    console.log("async1 start"); 
    await async2(); 
    console.log("async1 end"); 
} 
async function async2() { 
    console.log("async2"); 
    return Promise.resolve().then(() => { 
        console.log("async2-inner"); 
    }); 
} 

console.log("script start"); 
setTimeout(function () { 
    console.log("settimeout"); 
}); 

async1(); 
new Promise(function (resolve) { 
    console.log("promise1"); 
    resolve(); 
}) 
.then(function () { 
    console.log("promise2"); 
}) 
.then(function () { 
    console.log("promise3"); 
}) 
.then(function () { 
    console.log("promise4"); 
}); 
console.log("script end");
复制代码

感谢评论区贡献的题目

题解

这个问题,这里面涉及 async 中使用 await 会产生多个Promise链路的问题以及 resolve 值为 Promise 对象的问题,重点看 async2,我把他转化为这样(setTimeout对于本题悬念不大,就删除了)。

async function async1() {
    console.log("async1 start");
    let a2 = async2();
    await a2
    console.log("async1 end");
}
async function async2() {
    console.log("async2");
    let p1 = Promise.resolve()
    let p2 = p1.then(() => {
        console.log("async2-inner");
    })
    return p2;
}

let a1 = async1();

let p3 = new Promise(function (resolve) {
    console.log("promise1");
    resolve();
})

let p4 = p3.then(function () {
    console.log("promise2");
})
// 为 p3 添加 reactions
let p5 = p4.then(function () {
    console.log("promise3");
})
// 为 p4 添加 reactions
let p6 = p5.then(function () {
    console.log("promise4");
});
// 为 p5 添加 reactions
console.log("script end");
复制代码

想必你也发现了 async 函数中 await 语句之前的代码都是同步执行的(相当于Promsie的executor)

  1. 先调用 async1,输出 async1 start, 同步执行到 async2() 的位置,然后去同步执行 async2。

然后输出 async2,里面创建一个 fulfilled 状态的 p1,然后为 p1 绑定 then,因为 p1 是 fulfilled 状态所以 p1.onFulfilled 会立即进入 microtask 队列。这时 microtask 队列就变成这样:

[p1.onFulfilled]
复制代码

然后返回 p2(resolve(p2)),又因为 p2 是一个 Promise 对象,所以创建一个如下的 promiseResolveThenableJobTask

let promiseResolveThenableJobTask = () => {
    p2.then((value) => { 
        ReslovePromise(a2, value) // ReslovePromise 的作用上面有介绍
    })
}
复制代码
[p1.onFulfilled,promiseResolveThenableJobTask]
复制代码

2 . 然后执行 await a2,这里很关键,await 会等待一个 Promsie 进入 fulfilled 状态后才执行后面的代码,其实就相当于下面这样

a2.then(_ => {
 // 这里是 async1 中 await 后的代码
})
// 为 a2 绑定了 reactions,这里的 onFulfill 暂时就叫 『async1后半段』吧
// 其实这里面做的事情很多,我后面可能会单独讲解 async/await 的原理
复制代码

注意此时 a2 还不是 fulfilled 状态,因为他需要等待 promiseResolveThenableJobTask 执行时来调用他的 resolve 才会变成 fulfilled。

3 . 这时 async1() 触发的同步代码才执行完毕,继续执行后面的 new Promise

同步执行这段代码

function (resolve) {
    console.log("promise1");
    resolve();
}
复制代码

输出 promise1, 执行 resolve, 然后 p3 状态变为 fulfilled,p3.onFulfilled 进入队列,后面的 then 都是给对应的 promsie 绑定 reactions 这个就不说了,最后输出 script end

到此时所有同步代码执行完成, microtask 队列是这样的:

[p1.onFulfilled,promiseResolveThenableJobTask,p3.onFulfilled]
复制代码

4 . 至此所有同步代码执行完成,开始取 microtask 执行,首先是 p1.onFulfilleed ,执行输出 async2-inner, 然后 将其返回值 undefined 作为 p2 的值,并将 p2 变成 fulfilled 状态。因为 p2 此时没有 reactions (也就是没有被调用过then方法),所以不会发生什么事情

[promiseResolveThenableJobTask,p3.onFulfilled]
复制代码

5 . promiseResolveThenableJobTask 出队列执行, 其内容如下,上面已经说过了

let promiseResolveThenableJobTask = () => {
    p2.then((value) => { 
        ReslovePromise(a2, value) // ReslovePromise 的作用上面有介绍
    })
}
复制代码

执行是执行 p2 的 then 方法为其绑定 onFulfilled 处理函数,但是 p2 已经是 fulfilled 状态,所以会直接将 p2.onFulfilled 加入 microtask 队列。

[p3.onFulfilled, p2.onFulfilled]
复制代码

6 . p3.onFulfilled 出队执行,输出 promise2 ,将 p4 的状态变为 fulfilled,p4的值为其1返回值也就是undefined,然后 p4 的 onFulfilled 也会加入 microtask 队列

[p2.onFulfilled, p4.onFulfilled]
复制代码

7 . p2.onFulfilled 出队列执行, p2.onFulfilled 的内容如下,这个上面说过

(value) => { 
    ReslovePromise(a2, value) // 也就是 a2 的 resolve(value)
}
复制代码

所以执行 ReslovePromise 后,a2 会变成 fulfilled 状态,a2.onFulfilled 也就是 『async1后半段』 也理所当然的进入 microtask 队列

[p4.onFulfilled, async1后半段]
复制代码

8 . 后面的结果就没有什么难点了,p4.onFulfilled 出队执行,输出 promise3,然后 p5.onFulfilled 入队

[async1后半段,p5.onFulfilled]
复制代码

9 . async1后半段 出队执行,输出 async1 end, 然后 a1 状态变为 fulfilled,但是没有绑定任何处理函数,所以 a1 就没有后续了

[p5.onFulfilled]
复制代码

10 . p5.onFulfilled 出队执行输出 promise4,同理 p6 没有绑定任何处理函数,至此所有代码执行完成

最后几件事

  1. 如果对本文有任何问题请评论留言
  2. 如果你回顾了本文还是无法得到上述题目的答案,请评论区告知,我后序会给出详细的执行过程介绍
  3. 如果你有任何 Promise 问题,可评论,作者免费承包所有 Promise 问题
  4. 如果你看到了这里却还没有点赞,请点赞,非常感谢。

Copyright© 2013-2020

All Rights Reserved 京ICP备2023019179号-8