草庐IT

c++ - 我应该按什么顺序发送 callback() 并通知服务员？

coder 2023-11-17 原文

我有一个类，通过它可以异步提供一些服务(也可以同步进行相同的调用)。当被请求时，此类的对象(比如运算符)在不同的线程中启动操作。其他对象可以注册到 operator 对象的通知，以便在操作结束时调用此对象上的 OperationEnded() 方法。其他对象也可以通过在运算符对象上调用 Wait() 来等待此操作的完成。

运行结束时的代码大致如下:

_opEndedMutex.lock();
_thereIsOngoingOp = false;
_opEndedCondition.notify_all();
_opEndedMutex.unlock();

//no more call after notification
m_spNotificationManager->OperationEnded();

wait()函数如下:

boost::unique_lock<boost::mutex> lock(_opEndedMutex);
while(_thereIsOngoingOp)
{
    _opEndedCondition.wait(_opEndedMutex);
}

问题是关于资源管理的。这是一个 C++ 类，因此当检测到操作结束时，此类的用户可以删除运算符对象(如果有任何事件操作，析构函数将等待完成)。操作的结束可以通过等待或接受通知来检测。因此，如果我先调用 _opEndedCondition.notify_all() 并且用户删除了运算符对象，它可能会在尝试调用 OperationEnded() 时崩溃，因为 m_spNotificationManager 已被删除。如果选择先调用 OperationEnded() 并且用户在此调用期间删除了运算符对象，则它可能会在尝试访问 _opEndedMutex、_thereIsOngoingOp 和 _opEndedCondition 时崩溃。

作为解决方案，我想到的第一件事是使用新的互斥锁来保护这两个调用。这看起来不太好，因为我无法预见如果引入新的互斥锁以及如果在 OperationEnded() 通知中用户同步启动新操作会发生什么。我也不确定如何在 wait() 方法中使用新的互斥量。

note1:这个API既有我们自己公司的应用，也有其他公司的应用。所以我无法摆脱任何一种同步机制。

note2:我修改了原代码、变量名和方法名，可能有错别字，但思路应该清晰。

编辑1:

算子对象保存在一个通过工厂生成的共享库中，然后通过一个接口(interface)暴露给外界。 因此，运算符对象的典型生命周期为:

IOperator * op = factory:getNewOperator();
//perform operations with op
op->Release() //this one goes and deletes the op object

另请注意，运算符对象是可重用的。客户端代码可以使一个新的运算符对象多次使用它并在最后删除它。

最佳答案

你有几个解决办法:

  • 您可以从 std::enable_shared_from_this 中专门化您的操作对象.这将意味着在客户端代码中，您不再删除该对象，而是将一个 std::shared_ptr 设置为 nullptr，并且不关心该对象何时被实际删除。

  • 您可以在计时器延迟时实现有限的垃圾收集:当您在客户端代码中收到 OperationEnded() 通知时，您获取指针并将其放入队列中，同时添加对象时的时间戳。然后，队列将有一个事件对象，该对象在计时器上唤醒，获取当前时间，如果时间戳(比方说)至少比当前时间早五秒，则将其删除。

  • 您可以使用 object pool 分配和取消分配操作类.当一个对象不再被使用时，它实际上并没有被删除，而是作为一个空闲(回收)对象放置在池中。在您完成处理后，当池被销毁时，该对象实际上会被删除。

  • 您可以为您的对象创建一个生命周期管理器，它会删除您的操作对象，然后发送通知。

  • 您可以让您的“OperationEnded”函数调用 delete this; 结束；然后，您将实现客户端代码以在收到通知时简单地将指针设置为 NULL；虽然这样的解决方案很脆弱，但在您的实现中，这可能只是将问题转移到另一段代码。

  • 最后，您可以实现所有这些的自定义组合。

关于c++ - 我应该按什么顺序发送 callback() 并通知服务员？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/21879123/

ampcallback运算符OperationEndedsectionc++multithreadingthread-safety

有关c++ - 我应该按什么顺序发送 callback() 并通知服务员？的更多相关文章

  1. ruby - 为什么我可以在 Ruby 中使用 Object#send 访问私有(private)/ protected 方法？ - 2

    类classAprivatedeffooputs:fooendpublicdefbarputs:barendprivatedefzimputs:zimendprotecteddefdibputs:dibendendA的实例a=A.new测试a.foorescueputs:faila.barrescueputs:faila.zimrescueputs:faila.dibrescueputs:faila.gazrescueputs:fail测试输出failbarfailfailfail.发送测试[:foo,:bar,:zim,:dib,:gaz].each{|m|a.send(m)resc

  2. ruby - 使用 ruby​​ 和 savon 的 SOAP 服务 - 2

    我正在尝试使用ruby​​和Savon来使用网络服务。测试服务为http://www.webservicex.net/WS/WSDetails.aspx?WSID=9&CATID=2require'rubygems'require'savon'client=Savon::Client.new"http://www.webservicex.net/stockquote.asmx?WSDL"client.get_quotedo|soap|soap.body={:symbol=>"AAPL"}end返回SOAP异常。检查soap信封，在我看来soap请求没有正确的命名空间。任何人都可以建议我

  3. ruby-on-rails - Rails - 子类化模型的设计模式是什么？ - 2

    我有一个模型:classItem项目有一个属性“商店”基于存储的值，我希望Item对象对特定方法具有不同的行为。Rails中是否有针对此的通用设计模式？如果方法中没有大的if-else语句，这是如何干净利落地完成的？ 最佳答案 通常通过Single-TableInheritance. 关于ruby-on-rails-Rails-子类化模型的设计模式是什么？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.co

  4. ruby - 具有身份验证的私有(private) Ruby Gem 服务器 - 2

    我想安装一个带有一些身份验证的私有(private)Rubygem服务器。我希望能够使用公共(public)Ubuntu服务器托管内部gem。我读到了http://docs.rubygems.org/read/chapter/18.但是那个没有身份验证-如我所见。然后我读到了https://github.com/cwninja/geminabox.但是当我使用基本身份验证(他们在他们的Wiki中有)时，它会提示从我的服务器获取源。所以。如何制作带有身份验证的私有(private)Rubygem服务器？这是不可能的吗？谢谢。编辑:Geminabox问题。我尝试“捆绑”以安装新的gem..

  5. ruby-on-rails - Rails 常用字符串(用于通知和错误信息等) - 2

    大约一年前，我决定确保每个包含非唯一文本的Flash通知都将从模块中的方法中获取文本。我这样做的最初原因是为了避免一遍又一遍地输入相同的字符串。如果我想更改措辞，我可以在一个地方轻松完成，而且一遍又一遍地重复同一件事而出现拼写错误的可能性也会降低。我最终得到的是这样的:moduleMessagesdefformat_error_messages(errors)errors.map{|attribute,message|"Error:#{attribute.to_s.titleize}#{message}."}enddeferror_message_could_not_find(obje

  6. ruby - 什么是填充的 Base64 编码字符串以及如何在 ruby​​ 中生成它们？ - 2

    我正在使用的第三方API的文档状态:"[O]urAPIonlyacceptspaddedBase64encodedstrings."什么是“填充的Base64编码字符串”以及如何在Ruby中生成它们。下面的代码是我第一次尝试创建转换为Base64的JSON格式数据。xa=Base64.encode64(a.to_json) 最佳答案 他们说的padding其实就是Base64本身的一部分。它是末尾的“=”和“==”。Base64将3个字节的数据包编码为4个编码字符。所以如果你的输入数据有长度n和n%3=1=>"=="末尾用于填充n%

  7. ruby - 解析 RDFa、微数据等的最佳方式是什么，使用统一的模式/词汇(例如 schema.org)存储和显示信息 - 2

    我主要使用Ruby来执行此操作，但到目前为止我的攻击计划如下:使用gemsrdf、rdf-rdfa和rdf-microdata或mida来解析给定任何URI的数据。我认为最好映射到像schema.org这样的统一模式，例如使用这个yaml文件，它试图描述数据词汇表和opengraph到schema.org之间的转换:#SchemaXtoschema.orgconversion#data-vocabularyDV:name:namestreet-address:streetAddressregion:addressRegionlocality:addressLocalityphoto:i

  8. ruby - 为什么 4.1%2 使用 Ruby 返回 0.0999999999999996？但是 4.2%2==0.2 - 2

    为什么4.1%2返回0.0999999999999996？但是4.2%2==0.2。 最佳答案 参见此处:WhatEveryProgrammerShouldKnowAboutFloating-PointArithmetic实数是无限的。计算机使用的位数有限(今天是32位、64位)。因此计算机进行的浮点运算不能代表所有的实数。0.1是这些数字之一。请注意，这不是与Ruby相关的问题，而是与所有编程语言相关的问题，因为它来自计算机表示实数的方式。 关于ruby-为什么4.1%2使用Ruby返

  9. ruby - 检查 "command"的输出应该包含 NilClass 的意外崩溃 - 2

    为了将Cucumber用于命令行脚本，我按照提供的说明安装了arubagem。它在我的Gemfile中，我可以验证是否安装了正确的版本并且我已经包含了require'aruba/cucumber'在'features/env.rb'中为了确保它能正常工作，我写了以下场景:@announceScenario:Testingcucumber/arubaGivenablankslateThentheoutputfrom"ls-la"shouldcontain"drw"假设事情应该失败。它确实失败了，但失败的原因是错误的:@announceScenario:Testingcucumber/ar

  10. ruby-on-rails - 如何优雅地重启 thin + nginx？ - 2

    我的瘦服务器配置了nginx，我的ROR应用程序正在它们上运行。在我发布代码更新时运行thinrestart会给我的应用程序带来一些停机时间。我试图弄清楚如何优雅地重启正在运行的Thin实例，但找不到好的解决方案。有没有人能做到这一点？ 最佳答案 #Restartjustthethinserverdescribedbythatconfigsudothin-C/etc/thin/mysite.ymlrestartNginx将继续运行并代理请求。如果您将Nginx设置为使用多个上游服务器，例如server{listen80;server

随机推荐