草庐IT

javascript - promise 中的超时循环在 promise 解决后永远不会执行?

coder 2025-03-30 原文

我遇到了一个问题,即从已解决的 promise 发送到 setTimeout 的回调永远不会执行。

假设我有以下内容:

class Foo {
  constructor(foo) {
    this.foo = foo;
  }

  async execUntilStop(callback) {
    const timeoutLoopCallback = () => {
      if (this.stopExec) return;
      callback({ data: 'data' });
      setTimeout(timeoutLoopCallback, 10);
    };
    setTimeout(timeoutLoopCallback, 10);

    return { data: 'data'};
  }

  stop() {
    this.stopExec = true;
  }
}

const myFunc = async function () {
  let callbackCalled = false;
  const callback = () => callbackCalled = true;
  foo = new Foo('foo');
  foo.execUntilStop(callback);
  const hasCallbackCalled = async () => callbackCalled;

  while(!(await hasCallbackCalled())) null;
  foo.stop();
  return 'success!';
};

myFunc().then((result) => console.log(result))

myFunc() 永远不会解析,因为它一直在等待 callbackCalledtrue

我在这里错过了什么?我相信事件循环不应该被阻止,因为我在异步函数上调用 await 来检查回调是否被调用。我假设它与 timeoutLoopCallback 绑定(bind)到已解决的 promise 有关,但我不是 JavaScript 专家,可以使用一些反馈。

注意:这看起来有点奇怪,但本质上这是我正在尝试为其编写测试用例的类的派生类,它将不断执行回调直到停止。


已解决

利用我从@traktor53 的回答中学到的知识,我编写了一个方便的花花公子 wait 函数:

// resolves when callback returns true
const wait = callback => new Promise((resolve, reject) => {
  const end = () => {
    try {
      if (callback()) {
        resolve(true);
      } else {
        setTimeout(end, 0);
      }
    } catch(error) {
      reject(error);
    }
  };
  setTimeout(end, 0);
});


class Foo {
  constructor(foo) {
    this.foo = foo;
  }

  async execUntilStop(callback) {
    const timeoutLoopCallback = () => {
      if (this.stopExec) return;
      callback({ data: 'data' });
      setTimeout(timeoutLoopCallback, 10);
    };
    setTimeout(timeoutLoopCallback, 10);

    return { data: 'data'};
  }

  stop() {
    this.stopExec = true;
  }
}

const myFunc = async function (num) {
  let callbackCalled = false;
  const callback = () => callbackCalled = true;
  foo = new Foo('foo');
  foo.execUntilStop(callback);

  const hasCallbackCalled = () => callbackCalled;
  await wait(hasCallbackCalled);
  foo.stop();
  return 'success!';
};

myFunc().then((result) => console.log(result)); // => success!

最佳答案

处理 promise 结算的作业进入 ECMAScript 标准中描述的“Promise 作业队列”(PJQ)。这种命名法在 HTML 文档中不常使用。

浏览器(和至少一个脚本引擎)将 PJQ 的作业放入通常称为“微任务队列”(MTQ) 的任务中。事件循环任务管理器在从事件循环的脚本调出返回时检查 MTQ,看它是否有任何作业,如果有,将弹出并执行队列中最旧的作业。原帖中的那一行

 while(!(await callbackCalled)) null;

(在第一次调用中相当于

while( !( await Promise.resolve( false));  // callbackCalled is false

)

将一个作业用于获取 Promise.resolve 返回的 promise 的结算值,并将其放入 MTQ 中,并通过让 await 运算符返回已完成的值继续执行,该值是 false.

因为浏览器处理 MTQ 的优先级高于定时器到期生成的任务,所以在 await 操作之后继续执行并立即执行循环的另一次迭代并将另一个作业放入 MTQ 以等待false 值,中间不处理任何计时器回调

这设置了一个异步无限循环(顺便说一句,祝贺你,我以前从未见过!),在这种情况下,我不希望定时器回调执行并调用 timeoutLoopCallback 一秒钟时间。

无限循环也阻止继续到下一行:

  foo.stop()

从不执行。

请注意,此处观察到的阻塞效应是“Promise Job Queue”的 HTML 实现的结果 - ECMAScript promise 选择不指定实际 JavaScript 系统的实现和优先级细节。所以归咎于 HTML 标准,而不是 ECMAScript :D

另请注意:将 await calledBackCalled 替换为 await hasCallbackCalled() 不会解决问题 - 将生成不同的 promise 作业,但 await 运算符仍会返回


(更新)既然你问了,

的实际步骤

 while(!(await hasCallbackCalled())) null;

是:

  1. 评估hasCallbackCalled()
  2. 'hasCallbackCalled` 是一个异步函数,返回一个由函数主体的返回值实现的 promise 。
  3. 函数体是同步代码,通过同步返回callbackCalled的值(false)来完成第一次调用时返回的promise
  4. 到目前为止,异步函数返回的 promise 已同步实现,值为 false
  5. await 现在通过调用 .then 在步骤 4 中获得的 promise 上添加处理程序,让 await 知道已结算的值和状态(在本例中为“已完成”)。
  6. 但是在已完成的 promise 上调用 then 同步 会插入一个作业,以将已完成的处理程序与已完成的值一起调用到 MTQ 中
  7. MTQ 现在有一个工作来为这个特定的 await 调用代码;
  8. await 返回到事件循环管理器。
  9. MTQ 作业现在执行在步骤 5 中添加的 then 处理程序,
  10. then 处理程序恢复 await 运算符处理,将值 false 返回给用户脚本。
  11. while 循环测试从步骤 1 继续执行。

关于javascript - promise 中的超时循环在 promise 解决后永远不会执行?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50032131/

有关javascript - promise 中的超时循环在 promise 解决后永远不会执行?的更多相关文章

  1. ruby - 如何从 ruby​​ 中的字符串运行任意对象方法? - 2

    总的来说,我对ruby​​还比较陌生,我正在为我正在创建的对象编写一些rspec测试用例。许多测试用例都非常基础,我只是想确保正确填充和返回值。我想知道是否有办法使用循环结构来执行此操作。不必为我要测试的每个方法都设置一个assertEquals。例如:describeitem,"TestingtheItem"doit"willhaveanullvaluetostart"doitem=Item.new#HereIcoulddotheitem.name.shouldbe_nil#thenIcoulddoitem.category.shouldbe_nilendend但我想要一些方法来使用

  2. ruby - 其他文件中的 Rake 任务 - 2

    我试图在一个项目中使用rake,如果我把所有东西都放到Rakefile中,它会很大并且很难读取/找到东西,所以我试着将每个命名空间放在lib/rake中它自己的文件中,我添加了这个到我的rake文件的顶部:Dir['#{File.dirname(__FILE__)}/lib/rake/*.rake'].map{|f|requiref}它加载文件没问题,但没有任务。我现在只有一个.rake文件作为测试,名为“servers.rake”,它看起来像这样:namespace:serverdotask:testdoputs"test"endend所以当我运行rakeserver:testid时

  3. ruby-on-rails - Ruby net/ldap 模块中的内存泄漏 - 2

    作为我的Rails应用程序的一部分,我编写了一个小导入程序,它从我们的LDAP系统中吸取数据并将其塞入一个用户表中。不幸的是,与LDAP相关的代码在遍历我们的32K用户时泄漏了大量内存,我一直无法弄清楚如何解决这个问题。这个问题似乎在某种程度上与LDAP库有关,因为当我删除对LDAP内容的调用时,内存使用情况会很好地稳定下来。此外,不断增加的对象是Net::BER::BerIdentifiedString和Net::BER::BerIdentifiedArray,它们都是LDAP库的一部分。当我运行导入时,内存使用量最终达到超过1GB的峰值。如果问题存在,我需要找到一些方法来更正我的代

  4. ruby-on-rails - Rails 3 中的多个路由文件 - 2

    Rails2.3可以选择随时使用RouteSet#add_configuration_file添加更多路由。是否可以在Rails3项目中做同样的事情? 最佳答案 在config/application.rb中:config.paths.config.routes在Rails3.2(也可能是Rails3.1)中,使用:config.paths["config/routes"] 关于ruby-on-rails-Rails3中的多个路由文件,我们在StackOverflow上找到一个类似的问题

  5. ruby-openid:执行发现时未设置@socket - 2

    我在使用omniauth/openid时遇到了一些麻烦。在尝试进行身份验证时,我在日志中发现了这一点:OpenID::FetchingError:Errorfetchinghttps://www.google.com/accounts/o8/.well-known/host-meta?hd=profiles.google.com%2Fmy_username:undefinedmethod`io'fornil:NilClass重要的是undefinedmethodio'fornil:NilClass来自openid/fetchers.rb,在下面的代码片段中:moduleNetclass

  6. ruby - 树顶语法无限循环 - 2

    我脑子里浮现出一些关于一种新编程语言的想法,所以我想我会尝试实现它。一位friend建议我尝试使用Treetop(Rubygem)来创建一个解析器。Treetop的文档很少,我以前从未做过这种事情。我的解析器表现得好像有一个无限循环,但没有堆栈跟踪;事实证明很难追踪到。有人可以指出入门级解析/AST指南的方向吗?我真的需要一些列出规则、常见用法等的东西来使用像Treetop这样的工具。我的语法分析器在GitHub上,以防有人希望帮助我改进它。class{initialize=lambda(name){receiver.name=name}greet=lambda{IO.puts("He

  7. ruby-on-rails - 在 Ruby 中循环遍历多个数组 - 2

    我有多个ActiveRecord子类Item的实例数组,我需要根据最早的事件循环打印。在这种情况下,我需要打印付款和维护日期,如下所示:ItemAmaintenancerequiredin5daysItemBpaymentrequiredin6daysItemApaymentrequiredin7daysItemBmaintenancerequiredin8days我目前有两个查询,用于查找maintenance和payment项目(非排他性查询),并输出如下内容:paymentrequiredin...maintenancerequiredin...有什么方法可以改善上述(丑陋的)代

  8. ruby-on-rails - Rails - 一个 View 中的多个模型 - 2

    我需要从一个View访问多个模型。以前,我的links_controller仅用于提供以不同方式排序的链接资源。现在我想包括一个部分(我假设)显示按分数排序的顶级用户(@users=User.all.sort_by(&:score))我知道我可以将此代码插入每个链接操作并从View访问它,但这似乎不是“ruby方式”,我将需要在不久的将来访问更多模型。这可能会变得很脏,是否有针对这种情况的任何技术?注意事项:我认为我的应用程序正朝着单一格式和动态页面内容的方向发展,本质上是一个典型的网络应用程序。我知道before_filter但考虑到我希望应用程序进入的方向,这似乎很麻烦。最终从任何

  9. ruby-on-rails - Rails 3.2.1 中 ActionMailer 中的未定义方法 'default_content_type=' - 2

    我在我的项目中添加了一个系统来重置用户密码并通过电子邮件将密码发送给他,以防他忘记密码。昨天它运行良好(当我实现它时)。当我今天尝试启动服务器时,出现以下错误。=>BootingWEBrick=>Rails3.2.1applicationstartingindevelopmentonhttp://0.0.0.0:3000=>Callwith-dtodetach=>Ctrl-CtoshutdownserverExiting/Users/vinayshenoy/.rvm/gems/ruby-1.9.3-p0/gems/actionmailer-3.2.1/lib/action_mailer

  10. ruby - Highline 询问方法不会使用同一行 - 2

    设置:狂欢ruby1.9.2高线(1.6.13)描述:我已经相当习惯在其他一些项目中使用highline,但已经有几个月没有使用它了。现在,在Ruby1.9.2上全新安装时,它似乎不允许在同一行回答提示。所以以前我会看到类似的东西:require"highline/import"ask"Whatisyourfavoritecolor?"并得到:Whatisyourfavoritecolor?|现在我看到类似的东西:Whatisyourfavoritecolor?|竖线(|)符号是我的终端光标。知道为什么会发生这种变化吗? 最佳答案

随机推荐