我目前正在阅读 Anthony Williams 的 C++ Concurrency in Action。他的一个 list 显示了这段代码,他声明了 z != 0 的断言。可以火。
#include <atomic>
#include <thread>
#include <assert.h>
std::atomic<bool> x,y;
std::atomic<int> z;
void write_x()
{
x.store(true,std::memory_order_release);
}
void write_y()
{
y.store(true,std::memory_order_release);
}
void read_x_then_y()
{
while(!x.load(std::memory_order_acquire));
if(y.load(std::memory_order_acquire))
++z;
}
void read_y_then_x()
{
while(!y.load(std::memory_order_acquire));
if(x.load(std::memory_order_acquire))
++z;
}
int main()
{
x=false;
y=false;
z=0;
std::thread a(write_x);
std::thread b(write_y);
std::thread c(read_x_then_y);
std::thread d(read_y_then_x);
a.join();
b.join();
c.join();
d.join();
assert(z.load()!=0);
}
Thread a (x is now true) Thread c (fails to increment z) Thread b (y is now true) Thread d (increments z) assertion cannot fire
Thread b (y is now true) Thread d (fails to increment z) Thread a (x is now true) Thread c (increments z) assertion cannot fire
Thread a (x is true) Thread b (y is true) Thread c (z is incremented) assertion cannot fire Thread d (z is incremented)

y还与 read_x_then_y 中的负载同步,和店铺到x与负载同步 read_y_then_x ?我很困惑。thread a ( write_x ) 存储到 x然后它到目前为止所做的所有工作都与读取 x 的任何其他线程同步。与获取订购。曾经read_x_then_y看到这一点,它跳出循环并读取 y .现在,可能会发生两件事。在一种选择中,write_y已写信给 y , 表示此版本将与 if 语句 (load) 同步,意思是 z递增并且断言不能触发。另一个选项是如果 write_y还没有运行,这意味着 if 条件失败并且 z 没有增加,在这种情况下,只有 x是真的和y仍然是假的。一旦 write_y 运行,read_y_then_x 就会跳出它的循环,但是两者都是 x和 y是真的和z递增并且断言不会触发。我想不出任何“运行”或内存排序在哪里 z永远不会增加。有人可以解释我的推理哪里有缺陷吗?最佳答案
您正在考虑顺序一致性,即最强(和默认)的内存顺序。如果使用这个内存顺序,所有对原子变量的访问构成一个全序,断言确实不能触发。
然而,在这个程序中,使用了较弱的内存顺序(释放存储和获取加载)。这意味着,根据定义,您不能假设操作的总顺序。特别是,您不能假设更改对其他线程以相同的顺序可见。 (对于任何原子内存顺序,仅保证每个单独变量的总顺序,包括 memory_order_relaxed 。)
本店至x和 y发生在不同的线程上,它们之间没有同步。 x的负载和 y发生在不同的线程上,它们之间没有同步。这意味着完全允许线程 c 看到 x && ! y和线程 d 看到 y && ! x . (我只是在此处缩写了获取加载,不要将此语法视为顺序一致的加载。)
底线:一旦您使用比顺序一致更弱的内存顺序,您就可以亲吻所有原子的全局状态的概念,即所有线程之间一致,再见。这正是为什么这么多人建议坚持顺序一致性的原因,除非您需要性能(顺便说一句,请记住衡量它是否更快!)并且确定您在做什么。另外,获得第二意见。
现在,你是否会被这个烧伤,是一个不同的问题。该标准仅允许基于用于描述标准要求的抽象机器的断言失败的场景。但是,由于某种原因,您的编译器和/或 CPU 可能不会利用此限额。因此,对于给定的编译器和 CPU,您可能永远不会在实践中看到触发了断言。请记住,编译器或 CPU 可能总是使用比您要求的更严格的内存顺序,因为这永远不会违反标准的最低要求。它可能只会让您损失一些性能——但无论如何标准都没有涵盖这一点。
更新以回应评论:该标准没有定义一个线程看到另一个线程对原子的更改所需的时间上限。向实现者建议值最终应该变得可见。
有顺序保证,但与您的示例相关的保证不会阻止断言触发。基本的获取-释放保证是,如果:
x x , 对 f 中的任何操作都是可见的,也就是说,在这个线程中,在给定的负载之后排序。 [请注意,除了这两个线程之外,不提供任何保证!] x 的一些旧值.如果它不读取更新的值,那么加载也不会与存储同步,并且上面提到的任何依赖操作都没有顺序保证。atomic<unsigned> 的周期性增量(例如使用释放顺序)变量,初始化为 0,另一个线程周期性地从这个变量加载(例如,使用获取顺序),然后,除了最终包装外,后一个线程看到的值必须单调增加。但这遵循给定的排序规则:一旦后一个线程读取 5,在从 4 到 5 的增量之前发生的任何事情都是在读取 5 之后的任何事情的相对过去。 事实上,除了换行之外的减少是甚至不允许 memory_order_relaxed ,但是这个内存顺序并没有对访问其他变量的相对顺序(如果有的话)做出任何 promise 。
关于c++ - 使用 4 个线程获取/释放语义,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48383867/
我正在学习如何使用Nokogiri,根据这段代码我遇到了一些问题:require'rubygems'require'mechanize'post_agent=WWW::Mechanize.newpost_page=post_agent.get('http://www.vbulletin.org/forum/showthread.php?t=230708')puts"\nabsolutepathwithtbodygivesnil"putspost_page.parser.xpath('/html/body/div/div/div/div/div/table/tbody/tr/td/div
我有一个Ruby程序,它使用rubyzip压缩XML文件的目录树。gem。我的问题是文件开始变得很重,我想提高压缩级别,因为压缩时间不是问题。我在rubyzipdocumentation中找不到一种为创建的ZIP文件指定压缩级别的方法。有人知道如何更改此设置吗?是否有另一个允许指定压缩级别的Ruby库? 最佳答案 这是我通过查看rubyzip内部创建的代码。level=Zlib::BEST_COMPRESSIONZip::ZipOutputStream.open(zip_file)do|zip|Dir.glob("**/*")d
类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
很好奇,就使用rubyonrails自动化单元测试而言,你们正在做什么?您是否创建了一个脚本来在cron中运行rake作业并将结果邮寄给您?git中的预提交Hook?只是手动调用?我完全理解测试,但想知道在错误发生之前捕获错误的最佳实践是什么。让我们理所当然地认为测试本身是完美无缺的,并且可以正常工作。下一步是什么以确保他们在正确的时间将可能有害的结果传达给您? 最佳答案 不确定您到底想听什么,但是有几个级别的自动代码库控制:在处理某项功能时,您可以使用类似autotest的内容获得关于哪些有效,哪些无效的即时反馈。要确保您的提
假设我做了一个模块如下:m=Module.newdoclassCendend三个问题:除了对m的引用之外,还有什么方法可以访问C和m中的其他内容?我可以在创建匿名模块后为其命名吗(就像我输入“module...”一样)?如何在使用完匿名模块后将其删除,使其定义的常量不再存在? 最佳答案 三个答案:是的,使用ObjectSpace.此代码使c引用你的类(class)C不引用m:c=nilObjectSpace.each_object{|obj|c=objif(Class===objandobj.name=~/::C$/)}当然这取决于
我正在尝试使用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请求没有正确的命名空间。任何人都可以建议我
关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点?我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等),但我确实想创建一个输出文件。
我在我的项目目录中完成了compasscreate.和compassinitrails。几个问题:我已将我的.sass文件放在public/stylesheets中。这是放置它们的正确位置吗?当我运行compasswatch时,它不会自动编译这些.sass文件。我必须手动指定文件:compasswatchpublic/stylesheets/myfile.sass等。如何让它自动运行?文件ie.css、print.css和screen.css已放在stylesheets/compiled。如何在编译后不让它们重新出现的情况下删除它们?我自己编译的.sass文件编译成compiled/t
我想将html转换为纯文本。不过,我不想只删除标签,我想智能地保留尽可能多的格式。为插入换行符标签,检测段落并格式化它们等。输入非常简单,通常是格式良好的html(不是整个文档,只是一堆内容,通常没有anchor或图像)。我可以将几个正则表达式放在一起,让我达到80%,但我认为可能有一些现有的解决方案更智能。 最佳答案 首先,不要尝试为此使用正则表达式。很有可能你会想出一个脆弱/脆弱的解决方案,它会随着HTML的变化而崩溃,或者很难管理和维护。您可以使用Nokogiri快速解析HTML并提取文本:require'nokogiri'h
我想为Heroku构建一个Rails3应用程序。他们使用Postgres作为他们的数据库,所以我通过MacPorts安装了postgres9.0。现在我需要一个postgresgem并且共识是出于性能原因你想要pggem。但是我对我得到的错误感到非常困惑当我尝试在rvm下通过geminstall安装pg时。我已经非常明确地指定了所有postgres目录的位置可以找到但仍然无法完成安装:$envARCHFLAGS='-archx86_64'geminstallpg--\--with-pg-config=/opt/local/var/db/postgresql90/defaultdb/po