草庐IT

C++:释放构造函数中所需的障碍,该构造函数创建访问构造对象的线程

coder 2024-02-19 原文

如果我在构造函数中创建一个线程,并且如果该线程访问该对象,我是否需要在该线程访问该对象之前引入一个释放屏障?具体来说,如果我有下面的代码 ( wandbox link ),我是否需要在构造函数中锁定互斥量(注释掉的行)?我需要确保 worker_thread_ 看到对 run_worker_thread_ 的写入,这样它就不会立即退出。我意识到在这里使用原子 bool 值更好,但我有兴趣了解此处的内存排序含义。根据我的理解,我认为我确实需要在构造函数中锁定互斥锁,以确保构造函数中互斥锁的解锁提供的释放操作与 threadLoop 中的互斥锁锁定提供的获取操作同步() 通过调用 shouldRun()

class ThreadLooper {
 public:
   ThreadLooper(std::string thread_name)
       : thread_name_{std::move(thread_name)}, loop_counter_{0} {
        //std::lock_guard<std::mutex> lock(mutex_);
        run_worker_thread_ = true;
        worker_thread_ = std::thread([this]() { threadLoop(); });
        // mutex unlock provides release semantics
   }

   ~ThreadLooper() {
     {
        std::lock_guard<std::mutex> lock(mutex_);
        run_worker_thread_ = false;
     }
     if (worker_thread_.joinable()) {
       worker_thread_.join();
     }
     cout << thread_name_ << ": destroyed and counter is " << loop_counter_
          << std::endl;     
   }

 private:
  bool shouldRun() {
      std::lock_guard<std::mutex> lock(mutex_);
      return run_worker_thread_;
  }

  void threadLoop() {
    cout << thread_name_ << ": threadLoop() started running"
         << std::endl;
    while (shouldRun()) {
      using namespace std::literals::chrono_literals;
      std::this_thread::sleep_for(2s);
      ++loop_counter_;
      cout << thread_name_ << ": counter is " << loop_counter_ << std::endl;
    }
    cout << thread_name_
         << ": exiting threadLoop() because flag is false" << std::endl;
  }

  const std::string thread_name_;
  std::atomic_uint64_t loop_counter_;
  bool run_worker_thread_;
  std::mutex mutex_;
  std::thread worker_thread_;
};

这也让我更普遍地考虑是否要在构造函数中初始化一堆常规 int(非原子)成员变量,然后通过一些公共(public)方法从其他线程读取这些成员变量,如果我需要类似地锁定除了在读取这些变量的方法中之外,构造函数中的互斥锁。这对我来说似乎与上面的情况略有不同,因为我知道该对象将在任何其他线程访问它之前被完全构造,但这似乎并不能确保该对象的初始化对其他线程不可见构造函数中的释放操作。

最佳答案

你不需要任何障碍因为它是guaranteed thread 构造函数与传递给它的函数的调用同步。 在标准语中:

The completion of the invocation of the constructor synchronizes with the beginning of the invocation of the copy of f.


有点正式的证明: run_worker_thread_ = true;(A) 在 thread 对象创建 (B) 之前排序>) 根据完整表达式 evaluation order . thread 对象构造同步闭包对象执行(C)根据上面引用的规则。因此,A inter-thread happens before C

B 之前的序列,B 与 C 同步,A 发生在 C 之前 -> 这是标准术语中的正式证明。

在 C++11+ 时代分析程序时,您应该坚持内存和执行的 C++ 模型,而忘记编译器可能会或可能不会做的障碍和重新排序。这些只是实现细节。唯一重要的是 C++ 术语中的形式证明。编译器必须遵守并做(和不做)任何它能遵守的规则。

但为了完整起见,让我们从编译器的角度来看代码,并尝试理解为什么在这种情况下它不能重新排序。我们都知道“as-if”规则,根据该规则编译器可能会在您无法判断它们已被重新排序时对某些指令进行重新排序。因此,如果我们有一些 bool 标志设置:

flag1 = true; // A
flag2 = false;// B

允许按如下方式执行这些行:

flag2 = false;// B
flag1 = true;// A

尽管 A 排序在 B 之前。它可以做到这一点,因为我们无法分辨差异,我们无法仅通过观察程序行为来捕捉它重新排序我们的指令,因为除了“先于排序”之外,没有任何关系在这些线之间。但是让我们回到我们的案例:

run_worker_thread_ = true; // A
worker_thread_ = std::thread(...); // B

看起来这种情况与上面的 bool 变量相同。如果我们不知道 thread 对象(除了在 A 表达式之后排序)与 something 同步(为简单起见,让我们忽略这一点)。但是正如我们发现的那样,如果某件事排在另一件事之前,而另一件事又与另一件事同步,那么它就发生在那件事之前。所以标准要求 A 表达式发生在我们的 B 表达式与之同步的东西之前。

并且这个事实禁止编译器重新排序我们的 AB 表达式,因为如果它这样做的话我们突然可以分辨出差异。因为如果它这样做了,那么 C 表达式(某物)可能看不到 A 提供的可见副作用。因此,仅通过观察程序执行,我们就可能发现作弊的编译器!因此,它必须使用一些障碍。不管它只是一个编译器障碍还是一个硬件障碍,它都必须存在以保证这些指令不会被重新排序。所以你可能认为它在构造完成时使用释放栅栏,在闭包对象执行时使用获取栅栏。这将粗略地描述幕后发生的事情。

看起来您也将互斥量视为某种神奇的东西,它总是有效并且不需要任何证明。所以出于某种原因,您相信 mutex 而不是 thread。但问题是它没有魔法,它唯一的保证是 lock 与之前的 unlock 同步,反之亦然。因此它提供了thread 提供的相同的保证

关于C++:释放构造函数中所需的障碍,该构造函数创建访问构造对象的线程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57670289/

有关C++:释放构造函数中所需的障碍,该构造函数创建访问构造对象的线程的更多相关文章

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

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

  2. 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

  3. ruby - 如何在 Ruby 中顺序创建 PI - 2

    出于纯粹的兴趣,我很好奇如何按顺序创建PI,而不是在过程结果之后生成数字,而是让数字在过程本身生成时显示。如果是这种情况,那么数字可以自行产生,我可以对以前看到的数字实现垃圾收集,从而创建一个无限系列。结果只是在Pi系列之后每秒生成一个数字。这是我通过互联网筛选的结果:这是流行的计算机友好算法,类机器算法:defarccot(x,unity)xpow=unity/xn=1sign=1sum=0loopdoterm=xpow/nbreakifterm==0sum+=sign*(xpow/n)xpow/=x*xn+=2sign=-signendsumenddefcalc_pi(digits

  4. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声? - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点?我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等),但我确实想创建一个输出文件。

  5. ruby-on-rails - 按天对 Mongoid 对象进行分组 - 2

    在控制台中反复尝试之后,我想到了这种方法,可以按发生日期对类似activerecord的(Mongoid)对象进行分组。我不确定这是完成此任务的最佳方法,但它确实有效。有没有人有更好的建议,或者这是一个很好的方法?#eventsisanarrayofactiverecord-likeobjectsthatincludeatimeattributeevents.map{|event|#converteventsarrayintoanarrayofhasheswiththedayofthemonthandtheevent{:number=>event.time.day,:event=>ev

  6. ruby - 使用 Vim Rails,您可以创建一个新的迁移文件并一次性打开它吗? - 2

    使用带有Rails插件的vim,您可以创建一个迁移文件,然后一次性打开该文件吗?textmate也可以这样吗? 最佳答案 你可以使用rails.vim然后做类似的事情::Rgeneratemigratonadd_foo_to_bar插件将打开迁移生成的文件,这正是您想要的。我不能代表textmate。 关于ruby-使用VimRails,您可以创建一个新的迁移文件并一次性打开它吗?,我们在StackOverflow上找到一个类似的问题: https://sta

  7. ruby-on-rails - 无法使用 Rails 3.2 创建插件? - 2

    我对最新版本的Rails有疑问。我创建了一个新应用程序(railsnewMyProject),但我没有脚本/生成,只有脚本/rails,当我输入ruby./script/railsgeneratepluginmy_plugin"Couldnotfindgeneratorplugin.".你知道如何生成插件模板吗?没有这个命令可以创建插件吗?PS:我正在使用Rails3.2.1和ruby​​1.8.7[universal-darwin11.0] 最佳答案 随着Rails3.2.0的发布,插件生成器已经被移除。查看变更日志here.现在

  8. ruby-on-rails - 在混合/模块中覆盖模型的属性访问器 - 2

    我有一个包含模块的模型。我想在模块中覆盖模型的访问器方法。例如:classBlah这显然行不通。有什么想法可以实现吗? 最佳答案 您的代码看起来是正确的。我们正在毫无困难地使用这个确切的模式。如果我没记错的话,Rails使用#method_missing作为属性setter,因此您的模块将优先,阻止ActiveRecord的setter。如果您正在使用ActiveSupport::Concern(参见thisblogpost),那么您的实例方法需要进入一个特殊的模块:classBlah

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

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

  10. ruby-on-rails - 如何验证非模型(甚至非对象)字段 - 2

    我有一个表单,其中有很多字段取自数组(而不是模型或对象)。我如何验证这些字段的存在?solve_problem_pathdo|f|%>... 最佳答案 创建一个简单的类来包装请求参数并使用ActiveModel::Validations。#definedsomewhere,atthesimplest:require'ostruct'classSolvetrue#youcouldevencheckthesolutionwithavalidatorvalidatedoerrors.add(:base,"WRONG!!!")unlesss

随机推荐