JS Promise 实现原理 – 手写符合 Promises/A+ 规范的异步解决方案

Promise通过状态机解决异步编程中的回调地狱问题,其核心是实现pending、fulfilled、rejected三种状态的不可逆转换及then方法链式调用;需遵循Promises/A+规范,重点处理resolvePromise过程以支持嵌套与异常捕获,并通过官方测试套件验证兼容性。

js promise 实现原理 - 手写符合 promises/a+ 规范的异步解决方案

Promise 的核心在于解决 JavaScript 异步编程中的回调地狱问题,并提供更优雅的错误处理机制。本质上,Promise 是一种状态机,它代表了一个异步操作的最终完成(或失败)及其结果值。手写 Promise 意味着要理解并实现这种状态转换和结果传递的机制。

解决方案

实现一个符合 Promises/A+ 规范的 Promise,需要关注以下几个关键点:

状态(States): Promise 必须有三种状态:

pending

(进行中)、

fulfilled

(已成功)和

rejected

(已失败)。状态一旦改变,就不能再次改变。

then

方法:

then

方法用于注册当 Promise 状态改变时要执行的回调函数。它可以被多次调用,并且必须返回一个新的 Promise。

解决过程(Resolution Procedure): 这是 Promise 实现中最复杂的部分,它定义了如何将 Promise 的状态从

pending

转换为

fulfilled

rejected

。特别需要处理

then

方法返回的 Promise 的解决,以及 Promise 链中的异常捕获。

一个简单的 Promise 实现的骨架如下:

function MyPromise(executor) {  let state = 'pending';  let value = undefined;  let reason = undefined;  let onFulfilledCallbacks = [];  let onRejectedCallbacks = [];  function resolve(val) {    if (state === 'pending') {      state = 'fulfilled';      value = val;      onFulfilledCallbacks.forEach(callback => callback(value));    }  }  function reject(rea) {    if (state === 'pending') {      state = 'rejected';      reason = rea;      onRejectedCallbacks.forEach(callback => callback(reason));    }  }  try {    executor(resolve, reject);  } catch (err) {    reject(err);  }  this.then = function(onFulfilled, onRejected) {    onFulfilled = typeof onFulfilled === 'function' ? onFulfilled : value => value;    onRejected = typeof onRejected === 'function' ? onRejected : reason => { throw reason };    let promise2 = new MyPromise((resolve, reject) => {      if (state === 'fulfilled') {        setTimeout(() => { // 确保 promise2 已经被创建          try {            let x = onFulfilled(value);            resolvePromise(promise2, x, resolve, reject);          } catch (e) {            reject(e);          }        }, 0);      }      if (state === 'rejected') {        setTimeout(() => {          try {            let x = onRejected(reason);            resolvePromise(promise2, x, resolve, reject);          } catch (e) {            reject(e);          }        }, 0);      }      if (state === 'pending') {        onFulfilledCallbacks.push(() => {          setTimeout(() => {            try {              let x = onFulfilled(value);              resolvePromise(promise2, x, resolve, reject);            } catch (e) {              reject(e);            }          }, 0);        });        onRejectedCallbacks.push(() => {          setTimeout(() => {            try {              let x = onRejected(reason);              resolvePromise(promise2, x, resolve, reject);            } catch (e) {              reject(e);            }          }, 0);        });      }    });    return promise2;  }}function resolvePromise(promise2, x, resolve, reject) {  if (promise2 === x) {    return reject(new TypeError('Chaining cycle detected for promise #'))  }  let called;  if ((typeof x === 'object' && x != null) || typeof x === 'function') {    try {      let 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);  }}

这段代码展示了一个基础的 Promise 实现,包括状态管理、

then

方法和异步执行。

resolvePromise

函数是解决过程的核心,它递归地处理 Promise 的嵌套,确保 Promise 链的正确执行。

如何处理 Promise 中的异常?

Promise 的异常处理主要依赖于

reject

函数和

then

方法的第二个参数(

onRejected

)。如果在

executor

函数或

onFulfilled

回调中抛出异常,Promise 的状态会变为

rejected

,并且异常会被传递给

onRejected

回调。如果没有提供

onRejected

回调,异常会被传递到 Promise 链的下一个

onRejected

回调,直到被捕获。

此外,可以使用

catch

方法来捕获 Promise 链中的所有异常。

catch

方法实际上是

then(null, onRejected)

的语法糖。

new MyPromise((resolve, reject) => {  throw new Error('Something went wrong!');}).then(() => {  // This will not be executed}).catch(error => {  console.error('Caught an error:', error); // Output: Caught an error: Error: Something went wrong!});

手写 Promise 时需要注意哪些性能优化?

性能优化是手写 Promise 时需要考虑的重要因素。以下是一些常见的优化策略:

避免不必要的异步操作: 如果 Promise 的结果已经可用,可以直接同步地调用

onFulfilled

onRejected

回调,而不需要使用

setTimeout

或其他异步机制。

减少 Promise 的创建: 频繁地创建 Promise 会增加内存消耗和垃圾回收的压力。尽量重用 Promise 实例,避免在循环或高频调用的函数中创建 Promise。

使用微任务队列: 使用

MutationObserver

process.nextTick

等微任务队列来调度回调函数,可以比

setTimeout

更快地执行回调,提高 Promise 的响应速度。但要注意,过度使用微任务队列可能会导致 UI 渲染阻塞。

避免深层 Promise 嵌套: 深层 Promise 嵌套会增加代码的复杂性和调试难度,并且可能导致性能问题。尽量使用

async/await

语法糖来简化异步代码,减少 Promise 的嵌套。

如何测试手写的 Promise 是否符合 Promises/A+ 规范?

要确保手写的 Promise 符合 Promises/A+ 规范,可以使用 Promises/A+ 官方提供的测试套件。该测试套件包含一系列测试用例,可以验证 Promise 的行为是否符合规范。

安装测试套件: 使用 npm 安装

promises-aplus-tests

包。

npm install promises-aplus-tests --save-dev

编写测试适配器: 创建一个测试适配器,将手写的 Promise 暴露给测试套件。

// adapter.jsconst MyPromise = require('./my-promise'); // 替换为你的 Promise 实现module.exports = {  deferred: function() {    let dfd = {};    dfd.promise = new MyPromise((resolve, reject) => {      dfd.resolve = resolve;      dfd.reject = reject;    });    return dfd;  },  resolved: MyPromise.resolve,  rejected: MyPromise.reject};

运行测试: 使用

promises-aplus-tests

命令运行测试,并指定测试适配器。

npx promises-aplus-tests adapter.js

测试套件会运行所有测试用例,并输出测试结果。如果所有测试都通过,则说明手写的 Promise 符合 Promises/A+ 规范。

请注意,这只是一个简化的实现,实际的 Promise 实现需要考虑更多的细节和边界情况,例如处理 Promise 的循环引用、处理

then

方法的返回值等。建议参考 Promises/A+ 规范和成熟的 Promise 库(例如 Bluebird)的源码,以获得更完整的理解。

以上就是JS Promise 实现原理 – 手写符合 Promises/A+ 规范的异步解决方案的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/67380.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年11月12日 11:54:45
下一篇 2025年11月12日 12:15:07

相关推荐

  • C++函数如何返回一个结构体对象以及返回值优化的作用

    C++中函数返回结构体最推荐的方式是按值返回,现代编译器通过返回值优化(RVO/NRVO)消除拷贝开销,直接在目标位置构造对象;若优化未生效,C++11的移动语义可避免深拷贝;C++17进一步对prvalue返回值实现强制拷贝省略,确保高效性。 在C++中,函数返回一个结构体对象最直接、也是现代C+…

    2025年12月18日
    000
  • C++如何在异常处理中处理多线程资源安全

    使用RAII管理资源,避免析构函数抛异常,通过std::exception_ptr传递跨线程异常,确保并发容器的异常安全,防止资源泄漏与死锁。 在C++多线程程序中,异常处理不仅要考虑逻辑正确性,还必须确保资源安全,比如锁、动态内存、文件句柄等不会因异常导致泄漏或死锁。异常可能在任意时刻中断执行流,…

    2025年12月18日
    000
  • C++如何使用指针访问数组中的特定元素

    数组名是首元素指针,可用指针算术访问元素,如*(ptr + i)等价于arr[i],指针操作提供高效安全的数组访问方式。 在C++中,指针和数组有着紧密的关系。数组名本质上是一个指向数组首元素的指针,因此可以通过指针操作来访问数组中的任意元素。 指针与数组的关系 当你声明一个数组时,例如: int …

    2025年12月18日
    000
  • C++复合对象数组与指针操作技巧

    处理C++复合对象数组与指针操作,关键在于理解对象生命周期与内存管理。动态数组需用new[]和delete[]配对,避免内存泄漏;含指针成员时应遵循“三/五法则”实现深拷贝,或使用智能指针;推荐用std::vector和范围for循环替代裸指针,提升安全与效率。 在C++的世界里,处理复合对象数组和…

    2025年12月18日
    000
  • C++抽象工厂模式与产品族实现技巧

    抽象工厂模式通过定义创建一系列相关对象的接口,实现产品族的统一创建与解耦,如GUI库中不同平台组件的生成,客户端无需关心具体实现,仅依赖抽象接口,提升代码灵活性与可维护性。 C++中的抽象工厂模式,在我看来,核心在于它提供了一种创建一系列相关或相互依赖对象的接口,而无需指定它们具体的类。简单来说,它…

    2025年12月18日
    000
  • C++如何在文件I/O中实现日志记录功能

    答案:通过封装Logger类实现带时间戳的文件日志记录,支持INFO、ERROR、DEBUG级别输出,使用ofstream追加写入并flush确保数据落盘。 在C++中实现文件I/O日志记录功能,核心是将程序运行时的信息输出到指定的日志文件中,便于调试和监控。实现方式可以简单也可以扩展,以下是一个实…

    2025年12月18日
    000
  • C++如何使用组合对象管理资源生命周期

    C++中通过组合对象实现RAII,将资源生命周期绑定对象生命周期。对象构造时获取资源,析构时自动释放,确保异常安全。如智能指针unique_ptr、shared_ptr管理内存,自定义FileHandle类封装文件操作,lock_guard管理互斥锁,均利用析构函数自动释放资源,避免泄露。 在C++…

    2025年12月18日
    000
  • C++对象初始化与成员访问技巧详解

    C++对象初始化需优先使用成员初始化列表,因其可提升效率、满足const和引用成员的强制初始化要求,并正确处理无默认构造函数的成员。 C++对象初始化,说白了,就是给新诞生的对象一个“初见礼”,确保它从一开始就处于一个有效且可用的状态。而成员访问,则是我们与对象内部数据和功能交互的桥梁。这两块儿,看…

    2025年12月18日
    000
  • C++复合对象与内存分配优化策略

    答案:优化C++复合对象内存分配需从减少动态分配、提升数据局部性、利用现代C++特性到自定义分配器逐步深入。应优先使用栈或智能指针管理生命周期,通过移动语义和emplace避免拷贝开销,注意深拷贝陷阱与内存碎片,并在性能瓶颈时引入内存池,结合placement new实现高效内存控制。 在C++的世…

    2025年12月18日
    000
  • C++在Linux系统下环境搭建常见坑及解决方案

    答案是:Linux下C++开发环境搭建需先安装编译工具链,如Ubuntu下用apt安装build-essential,CentOS下用yum或dnf安装Development Tools;编译器找不到时应检查g++是否安装,通过g++ –version验证;头文件缺失需使用-I指定路径或…

    2025年12月18日
    000
  • C++函数模板与类模板结合使用实例

    通过类模板定义通用数据结构,结合函数模板实现灵活操作,支持类型自动推导与转换,利用友元函数或公共接口访问私有成员,并可通过函数对象实现自定义逻辑,提升代码复用性与扩展性。 C++函数模板和类模板结合使用,能极大提升代码的灵活性和复用性。简单来说,就是用模板类来存储数据,然后用模板函数来操作这些数据,…

    2025年12月18日
    000
  • C++如何使用std::variant实现多类型安全存储

    std::variant是C++17提供的类型安全多类型存储方案,相比union和基类指针,它在编译期确定所有可能类型,避免运行时类型错误。它通过std::get、std::holds_alternative和std::visit等机制实现安全访问,其中std::visit结合lambda可优雅处理…

    2025年12月18日
    000
  • C++如何使用匿名组合类型简化代码

    匿名组合类型主要指匿名联合体和匿名结构体,其成员直接提升至外层作用域,无需通过中间实例名访问。与普通组合类型相比,它省去命名层级,使代码更简洁,但不改变内存布局。匿名联合体需手动管理成员生命周期,且易引发类型安全问题,推荐配合判别器使用,并优先考虑std::variant等现代C++替代方案以提升安…

    2025年12月18日
    000
  • C++如何结合策略模式优化算法选择

    策略模式通过封装不同算法为可互换对象,实现算法与客户端解耦,提升灵活性与可维护性;在C++中,借助抽象基类定义策略接口,具体策略类实现算法,上下文类通过智能指针持有策略并委托执行,客户端可动态切换算法;相比传统if-else方式,避免代码膨胀,符合开闭原则;算法选择需综合性能、数据特性、资源限制与业…

    2025年12月18日
    000
  • C++异常处理与类成员函数结合使用

    C++中异常处理与类成员函数结合可提升程序健壮性。成员函数可在错误时抛出异常,如栈空时抛出underflow_error;构造函数因无法返回错误码,常通过异常表明初始化失败,如文件打开失败时抛出runtime_error;noexcept用于标记不抛异常的函数,确保移动操作等性能关键路径安全;异常安…

    2025年12月18日
    000
  • C++如何使用back_inserter和front_inserter插入元素

    back_inserter通过push_back在容器末尾插入,front_inserter通过push_front在开头插入,前者适用于vector等,后者仅用于list、deque等支持前端插入的容器。 在C++中,back_inserter 和 front_inserter 是用于向容器中插入…

    2025年12月18日
    000
  • C++如何在复合类型中实现条件初始化

    在C++中实现复合类型成员的条件初始化,核心是利用构造函数的成员初始化器列表结合条件表达式、辅助函数或Lambda表达式,确保成员在对象构造时即被正确初始化。由于初始化器列表只接受表达式而非语句,无法直接使用if-else等控制结构,因此需通过三元运算符、私有辅助函数或立即调用的Lambda来封装条…

    2025年12月18日
    000
  • 如何将一个C++的结构体或对象以二进制形式写入文件

    使用fstream的write方法可将POD类型结构体直接以二进制写入文件,非POD类型需手动序列化,如处理string时先写长度再写内容,读取时按相同格式恢复数据。 在C++中,将结构体或对象以二进制形式写入文件,通常使用标准库中的 fstream,并配合 write() 方法进行操作。这种方式直…

    2025年12月18日
    000
  • C++shared_ptr自定义删除器使用方法

    shared_ptr的自定义删除器使其能灵活管理非内存资源,通过lambda、函数对象或普通函数指定释放逻辑,确保文件句柄、数组等资源安全释放,实现RAII。 shared_ptr 的自定义删除器,本质上是赋予了智能指针超越简单 delete 操作的能力,让我们能以更灵活、更安全的方式管理那些非内存…

    2025年12月18日
    000
  • C++如何使用std::unique_lock和std::lock_guard

    std::lock_guard适用于固定作用域的简单锁管理,而std::unique_lock提供延迟锁定、手动控制、条件变量配合等高级特性,适用于复杂同步场景。 在C++多线程编程中, std::unique_lock 和 std::lock_guard 都是用于管理互斥锁( std::mutex…

    2025年12月18日
    000

发表回复

登录后才能评论
关注微信