草庐IT

c++ - std::memory_order_relaxed 相对于相同原子变量的原子性

coder 2024-02-11 原文

关于内存顺序的 cppreference 文档说

Typical use for relaxed memory ordering is incrementing counters, such as the reference counters of std::shared_ptr, since this only requires atomicity, but not ordering or synchronization (note that decrementing the shared_ptr counters requires acquire-release synchronization with the destructor)



这是否意味着宽松的内存排序实际上不会导致相同变量的原子性?而只是导致与其他宽松的内存负载和/或 compare_exchange 的最终一致性。 ?使用 std::memory_order_seq_cststd::memory_order_relaxed 配对时,将是看到一致结果的唯一方法?

我假设 std::memory_order_relaxed对于同一个变量仍然是原子的,但不提供关于其他数据的加载和存储的任何其他约束。

最佳答案

您问了一些问题,但我将重点关注典型 shared_ptr 使用的排序约束。实现,因为我认为这涵盖了您问题的关键部分。
原子操作对于它所应用的变量(或 POD)总是原子的;对单个变量的修改将以一致的顺序对所有线程可见。
您的问题中描述了轻松原子操作的工作方式:

std::memory_order_relaxed is still atomic with respect to the same variable but does not provide any other constraints about loads and stores with respect to other data


以下是 2 个典型场景,其中可以省略对原子操作的排序约束(即使用 std::memory_order_relaxed):
  • 内存排序不是必需的,因为不依赖于其他操作,或者正如评论者所说,(..) 不是涉及其他内存位置的不变量的一部分。
    一个常见的例子是原子计数器,它由多个线程递增以跟踪特定事件发生的次数。
    如果计数器表示一个不依赖于其他操作的值,则可以放宽增量操作 ( fetch_add )。
    我发现 cppreference 给出的例子不是很有说服力,因为 shared_ptr引用计数确实有依赖性;即一旦其值变为零,内存就会被删除。
    一个更好的例子是 Web 服务器跟踪传入请求的数量,仅用于报告目的。
  • 内存排序是必要的,但是不需要使用排序约束,因为所需的同步已经过去了
    (IMO 这更好地解释了为什么 shared_ptr 的引用计数增量可以放宽,请参见下面的示例)。shared_ptr复制/移动构造函数只能在具有复制/移动自实例的(引用)同步 View 时调用(否则将是未定义的行为)
    因此,无需额外订购。

  • 以下示例说明了 shared_ptr 通常如何使用内存排序。实现修改其引用计数。假设所有线程并行运行
    之后 sp_main已被释放(shared_ptr 引用计数为 10)。
    int main()
    {
        std::vector<std::thread> v;
        auto sp_main = std::make_shared<int>(0);
    
        for (int i = 1; i <= 10; ++i)
        {
            // sp_main is passed by value
            v.push_back(thread{thread_func, sp_main, i});
        }
    
        sp_main.reset();
    
        for (auto &t : v)  t.join();
    }
    
    void thread_func(std::shared_ptr<int> sp, int n)
    {
        // 10 threads are created
    
        if (n == 7)
        {
            // Only thread #7 modifies the integer
            *sp = 42;
        }
    
        // The only thead with a synchronized view of the managed integer is #7
        // All other threads cannot read/write access the integer without causing a race
    
        // 'sp' going out of scope -> destructor called
    }
    
    线程创建保证了 make_shared 之间的(线程间)发生在之前的关系(在 main 中)和 sp的复制/移动构造函数(在每个线程内)。
    因此,shared_ptr的构造函数具有内存的同步 View 并且可以安全地递增 ref_count无需额外订购:
    ctrlblk->ref_count.fetch_add(1, std::memory_order_relaxed);
    
    对于销毁部分,因为只有线程 #7写入共享整数,其他 9 个线程不允许访问相同的内存位置而不会引起竞争。
    这会产生一个问题,因为所有线程大约在同一时间被销毁(假设 reset 中的 main 已经被调用过)
    并且只有一个线程将删除共享整数(将 ref_count 从 1 递减到 0 的那个)。
    最后一个线程在删除整数之前必须具有同步内存 View ,但由于 10 个线程中有 9 个没有同步 View ,因此需要额外排序。
    析构函数可能包含以下内容:
    if (ctrlblk->ref_count.fetch_sub(1, std::memory_order_acq_rel) == 1)
    {
        // delete managed memory
    }
    
    原子 ref_count具有单一的修改顺序,因此所有原子修改都以某种顺序发生。
    假设线程(在本例中)在 ref_count 上执行最后 3 次递减。是线程 #7 (3 → 2), #5 (2 → 1) 和 #3 (1 → 0)。
    线程执行的两个减量 #7#5#3 执行的修改顺序更早.
    发布顺序变为:

    #7 (store release) → #5 (read-modify-write, no ordering required) → #3 (load acquire)


    最终结果是线程#7执行的释放操作已与 #3 执行的获取操作同步并且整数修改(由 #7 )保证具有
    发生在整数销毁之前(由 #3 )。
    从技术上讲,只有访问托管内存位置的线程必须执行释放操作,但由于库实现者不知道线程操作,
    所有线程在销毁时执行释放操作。
    对于共享内存的最终销毁,技术上只有最后一个线程需要执行获取操作,因此 shared_ptr库实现者可以通过设置一个独立的围栏来优化
    仅由最后一个线程调用。
    if (ctrlblk->ref_count.fetch_sub(1, std::memory_order_release) == 1)
    {
        std::atomic_thread_fence(std::memory_order_acquire);
    
        // delete managed memory
    }
    

    关于c++ - std::memory_order_relaxed 相对于相同原子变量的原子性,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48124031/

    有关c++ - std::memory_order_relaxed 相对于相同原子变量的原子性的更多相关文章

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

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

    2. ruby - 使用 `+=` 和 `send` 方法 - 2

      如何将send与+=一起使用?a=20;a.send"+=",10undefinedmethod`+='for20:Fixnuma=20;a+=10=>30 最佳答案 恐怕你不能。+=不是方法,而是语法糖。参见http://www.ruby-doc.org/docs/ProgrammingRuby/html/tut_expressions.html它说Incommonwithmanyotherlanguages,Rubyhasasyntacticshortcut:a=a+2maybewrittenasa+=2.你能做的最好的事情是:

    3. ruby - 如何计算 Liquid 中的变量 +1 - 2

      我对如何计算通过{%assignvar=0%}赋值的变量加一完全感到困惑。这应该是最简单的任务。到目前为止,这是我尝试过的:{%assignamount=0%}{%forvariantinproduct.variants%}{%assignamount=amount+1%}{%endfor%}Amount:{{amount}}结果总是0。也许我忽略了一些明显的东西。也许有更好的方法。我想要存档的只是获取运行的迭代次数。 最佳答案 因为{{incrementamount}}将输出您的变量值并且不会影响{%assign%}定义的变量,我

    4. ruby-on-rails - rails group by 和 order by column - 2

      在我的Controller中,我得到了按类别分组的所有Extras:defindex@categories=Extra.all.group_by(&:category)end结果类似于哈希数组:{#=>[#,#=>[#,#]}我想按类别“排序”列而不是id排序,它应该如下所示:{#=>[#,#=>[#,#]}当我尝试时:defindex@categories=Extra.all.group_by(&:category).sort_by{|s|s[:sort]}end我得到“没有将符号隐式转换为整数”。那是因为我在“sort_by”中使用了一个符号吗? 最佳答

    5. arrays - Ruby 数组 += vs 推送 - 2

      我有一个数组数组,想将元素附加到子数组。+=做我想做的,但我想了解为什么push不做。我期望的行为(并与+=一起工作):b=Array.new(3,[])b[0]+=["apple"]b[1]+=["orange"]b[2]+=["frog"]b=>[["苹果"],["橙子"],["Frog"]]通过推送,我将推送的元素附加到每个子数组(为什么?):a=Array.new(3,[])a[0].push("apple")a[1].push("orange")a[2].push("frog")a=>[[“苹果”、“橙子”、“Frog”]、[“苹果”、“橙子”、“Frog”]、[“苹果”、“

    6. += 的 Ruby 方法 - 2

      有没有办法让Ruby能够做这样的事情?classPlane@moved=0@x=0defx+=(v)#thisiserror@x+=v@moved+=1enddefto_s"moved#{@moved}times,currentxis#{@x}"endendplane=Plane.newplane.x+=5plane.x+=10putsplane.to_s#moved2times,currentxis15 最佳答案 您不能在Ruby中覆盖复合赋值运算符。任务在内部处理。您应该覆盖+,而不是+=。plane.a+=b与plane.a=

    7. ruby-on-rails - 在 Ruby 或 Rails 中,hash.merge({ :order => 'asc' }) can return a new hash with a new key. 什么可以返回带有已删除键的新散列? - 2

      在Ruby(或Rails)中,我们可以做到new_params=params.merge({:order=>'asc'})现在new_params是一个带有添加键:order的散列。但是是否有一行可以返回带有已删除key的散列?线路new_params=params.delete(:order)不会工作,因为delete方法返回值,仅此而已。我们必须分3步完成吗?tmp_params=paramstmp_params.delete(:order)returntmp_params有没有更好的方法?因为我想做一个new_params=(params[:order].blank?||para

    8. ruby - 在 Ruby 中的另一个上下文中评估潜在的相对 URI - 2

      我在Ruby程序中有两个URI。一个肯定是绝对URI,另一个可能是绝对URI或相对URI。我想在第一个的上下文中将第二个转换为绝对URI,所以如果第一个是http://pupeno.com/blog第二个是/about,结果应该是http://pupeno.com/about.有什么想法吗? 最佳答案 Ruby的内置URI和Addressablegem,做这个简短的工作。我更喜欢Addressable,因为它功能更全面,但URI是内置的。require'uri'URI.join('http://pupeno.com/blog','/

    9. ruby - Sinatra + Heroku + Datamapper 使用 dm-sqlite-adapter 部署问题 - 2

      出于某种原因,heroku尝试要求dm-sqlite-adapter,即使它应该在这里使用Postgres。请注意,这发生在我打开任何URL时-而不是在gitpush本身期间。我构建了一个默认的Facebook应用程序。gem文件:source:gemcuttergem"foreman"gem"sinatra"gem"mogli"gem"json"gem"httparty"gem"thin"gem"data_mapper"gem"heroku"group:productiondogem"pg"gem"dm-postgres-adapter"endgroup:development,:t

    10. ruby - Ruby 中字符串运算符 + 和 << 的区别 - 2

      我是Ruby和这个网站的新手。下面两个函数是不同的,一个在函数外修改变量,一个不修改。defm1(x)x我想确保我理解正确-当调用m1时,对str的引用被复制并传递给将其视为x的函数。运算符当调用m2时,对str的引用被复制并传递给将其视为x的函数。运算符+创建一个新字符串,赋值x=x+"4"只是将x重定向到新字符串,而原始str变量保持不变。对吧?谢谢 最佳答案 String#+::str+other_str→new_strConcatenation—ReturnsanewStringcontainingother_strconc

    随机推荐