0

0

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

幻影之瞳

幻影之瞳

发布时间:2025-09-17 22:16:01

|

508人浏览过

|

来源于php中文网

原创

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

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

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

解决方案

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

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

    pending
    (进行中)、
    fulfilled
    (已成功)和
    rejected
    (已失败)。状态一旦改变,就不能再次改变。

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

  3. 解决过程(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 时需要考虑的重要因素。以下是一些常见的优化策略:

万知
万知

万知: 你的个人AI工作站

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

    onFulfilled
    onRejected
    回调,而不需要使用
    setTimeout
    或其他异步机制。

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

  3. 使用微任务队列: 使用

    MutationObserver
    process.nextTick
    等微任务队列来调度回调函数,可以比
    setTimeout
    更快地执行回调,提高 Promise 的响应速度。但要注意,过度使用微任务队列可能会导致 UI 渲染阻塞。

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

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

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

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

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

    promises-aplus-tests
    包。

    npm install promises-aplus-tests --save-dev
  2. 编写测试适配器: 创建一个测试适配器,将手写的 Promise 暴露给测试套件。

    // adapter.js
    const 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
    };
  3. 运行测试: 使用

    promises-aplus-tests
    命令运行测试,并指定测试适配器。

    npx promises-aplus-tests adapter.js

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

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

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

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
c语言中null和NULL的区别
c语言中null和NULL的区别

c语言中null和NULL的区别是:null是C语言中的一个宏定义,通常用来表示一个空指针,可以用于初始化指针变量,或者在条件语句中判断指针是否为空;NULL是C语言中的一个预定义常量,通常用来表示一个空值,用于表示一个空的指针、空的指针数组或者空的结构体指针。

237

2023.09.22

java中null的用法
java中null的用法

在Java中,null表示一个引用类型的变量不指向任何对象。可以将null赋值给任何引用类型的变量,包括类、接口、数组、字符串等。想了解更多null的相关内容,可以阅读本专题下面的文章。

458

2024.03.01

js正则表达式
js正则表达式

php中文网为大家提供各种js正则表达式语法大全以及各种js正则表达式使用的方法,还有更多js正则表达式的相关文章、相关下载、相关课程,供大家免费下载体验。

515

2023.06.20

js获取当前时间
js获取当前时间

JS全称JavaScript,是一种具有函数优先的轻量级,解释型或即时编译型的编程语言;它是一种属于网络的高级脚本语言,主要用于Web,常用来为网页添加各式各样的动态功能。js怎么获取当前时间呢?php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

244

2023.07.28

js 字符串转数组
js 字符串转数组

js字符串转数组的方法:1、使用“split()”方法;2、使用“Array.from()”方法;3、使用for循环遍历;4、使用“Array.split()”方法。本专题为大家提供js字符串转数组的相关的文章、下载、课程内容,供大家免费下载体验。

320

2023.08.03

js是什么意思
js是什么意思

JS是JavaScript的缩写,它是一种广泛应用于网页开发的脚本语言。JavaScript是一种解释性的、基于对象和事件驱动的编程语言,通常用于为网页增加交互性和动态性。它可以在网页上实现复杂的功能和效果,如表单验证、页面元素操作、动画效果、数据交互等。

5328

2023.08.17

js删除节点的方法
js删除节点的方法

js删除节点的方法有:1、removeChild()方法,用于从父节点中移除指定的子节点,它需要两个参数,第一个参数是要删除的子节点,第二个参数是父节点;2、parentNode.removeChild()方法,可以直接通过父节点调用来删除子节点;3、remove()方法,可以直接删除节点,而无需指定父节点;4、innerHTML属性,用于删除节点的内容。

481

2023.09.01

js截取字符串的方法
js截取字符串的方法

js截取字符串的方法有substring()方法、substr()方法、slice()方法、split()方法和slice()方法。本专题为大家提供字符串相关的文章、下载、课程内容,供大家免费下载体验。

212

2023.09.04

C++ 设计模式与软件架构
C++ 设计模式与软件架构

本专题深入讲解 C++ 中的常见设计模式与架构优化,包括单例模式、工厂模式、观察者模式、策略模式、命令模式等,结合实际案例展示如何在 C++ 项目中应用这些模式提升代码可维护性与扩展性。通过案例分析,帮助开发者掌握 如何运用设计模式构建高质量的软件架构,提升系统的灵活性与可扩展性。

8

2026.01.30

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
【web前端】Node.js快速入门
【web前端】Node.js快速入门

共16课时 | 2万人学习

Webpack4.x---十天技能课堂
Webpack4.x---十天技能课堂

共20课时 | 1.4万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号