在代码审查期间，我遇到了一段代码，基本上可以归结为:
#include <iostream>
#include <future>
#include <thread>
int main( int, char ** )
{
std::atomic<int> x( 0 );
std::future<void> task;
for( std::size_t i = 0u; i < 5u; ++i )
{
task = std::async( std::launch::async, [&x, i](){
std::this_thread::sleep_for( std::chrono::seconds( 2u * ( 5u - i ) ) );
++x;
} );
}
task.get();
std::cout << x << std::endl;
return 0;
}
我不太确定
我无法通过阅读互联网上的文档来回答这个问题，所以我想我会编写上面的代码片段来了解我们的编译器实际上做了什么。
现在，我发现 gcc-5 所做的事情的答案是优柔寡断的，这让我更加好奇:人们会假设分配是阻塞的或非阻塞的。
如果是阻塞的，那么程序所用的时间基本上应该是各个任务执行所用时间的总和。第一个需要 10 秒，第二个 8 秒，第三个 6 秒，第四个 4 秒，最后 2 秒。所以总共需要 10+8+6+4+2 = 30 秒。
如果是非阻塞的，应该和上一个任务一样长，即2秒。
发生的情况如下:需要 18 秒(使用时间 ./a.out 或旧时钟测量)。通过对代码进行一些操作，我发现代码的行为就像赋值是交替阻塞和非阻塞一样。
但这不可能是真的，对吧？ std::async 可能有一半时间回落到 std::deferred ？我的调试器说它会产生两个线程，阻塞直到两个线程都退出，然后再产生两个线程，依此类推。
标准是怎么说的？应该发生什么？ gcc-5 内部发生了什么？
最佳答案
一般来说，task 通过 operator=(&&) 的分配不必是阻塞的(见下文)，但由于您创建了 std::future 使用 std::async，这些分配变成阻塞(感谢@T.C.):
If the implementation chooses the launch::async policy,
[...]
the associated thread completion synchronizes with ([intro.multithread]) the return from the first function that successfully detects the ready status of the shared state or with the return from the last function that releases the shared state, whichever happens first.
在您的情况下发生的情况是 std::async 为您的 lambda 在分配启动“线程”-有关如何获得的详细说明，请参见下文执行时间为 18 秒。
这就是(可能)在您的代码中发生的情况(e 代表 epsilon):
t = 0，第一个std::async调用i = 0，开始一个新线程；t = 0 + e，第二个 std::async 调用，i = 1 开始一个新线程，然后移动。此举将释放 task 当前的共享状态，阻塞约 10 秒(但第二个 std::async 与 i = 1 已经在执行)；t = 10，第三个 std::async 调用，i = 2 开始一个新线程，然后移动。 task 的当前共享状态是调用 i = 1，它已经准备好，所以没有阻塞；t = 10 + e，第四次 std::async 调用，i = 3 开始一个新线程，然后移动。移动是阻塞的，因为之前 i = 2 的 std::async 尚未准备好，但 i = 3 的线程已经启动； t = 16，第五次 std::async 调用，i = 4 开始一个新线程，然后移动。 task (i = 3)的当前共享状态已经就绪，所以非阻塞；t = 16 + e，跳出循环，调用.get()等待*shared state`准备好；t = 18，shared state 准备就绪，整个事情就结束了。std::future::operator=的标准细节:这是 std::future 上 operator= 的标准报价:
future& operator=(future&& rhs) noexcept;Effects:
- (10.1) — releases any shared state (30.6.4).
- ...
这是“释放任何共享状态”的意思(重点是我的):
When an asynchronous return object or an asynchronous provider is said to release its shared state, it means:
(5.1) — [...]
(5.2) — [...]
(5.3) — these actions will not block for the shared state to become ready, except that it may block if all of the following are true: the shared state was created by a call to std::async, the shared state is not yet ready, and this was the last reference to the shared state.
您的情况属于我所强调的(我认为)。您使用 std::async 创建了共享状态，它正在休眠(所以还没有准备好)并且您只有一个对它的引用，所以这可能被阻塞了。
关于c++ - 重新分配给尚未准备好的 future 时会发生什么，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/38141229/
类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
我有一个模型:classItem项目有一个属性“商店”基于存储的值，我希望Item对象对特定方法具有不同的行为。Rails中是否有针对此的通用设计模式？如果方法中没有大的if-else语句，这是如何干净利落地完成的？ 最佳答案 通常通过Single-TableInheritance. 关于ruby-on-rails-Rails-子类化模型的设计模式是什么？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.co
我正在使用的第三方API的文档状态:"[O]urAPIonlyacceptspaddedBase64encodedstrings."什么是“填充的Base64编码字符串”以及如何在Ruby中生成它们。下面的代码是我第一次尝试创建转换为Base64的JSON格式数据。xa=Base64.encode64(a.to_json) 最佳答案 他们说的padding其实就是Base64本身的一部分。它是末尾的“=”和“==”。Base64将3个字节的数据包编码为4个编码字符。所以如果你的输入数据有长度n和n%3=1=>"=="末尾用于填充n%
我主要使用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
为什么4.1%2返回0.0999999999999996？但是4.2%2==0.2。 最佳答案 参见此处:WhatEveryProgrammerShouldKnowAboutFloating-PointArithmetic实数是无限的。计算机使用的位数有限(今天是32位、64位)。因此计算机进行的浮点运算不能代表所有的实数。0.1是这些数字之一。请注意，这不是与Ruby相关的问题，而是与所有编程语言相关的问题，因为它来自计算机表示实数的方式。 关于ruby-为什么4.1%2使用Ruby返
我的瘦服务器配置了nginx，我的ROR应用程序正在它们上运行。在我发布代码更新时运行thinrestart会给我的应用程序带来一些停机时间。我试图弄清楚如何优雅地重启正在运行的Thin实例，但找不到好的解决方案。有没有人能做到这一点？ 最佳答案 #Restartjustthethinserverdescribedbythatconfigsudothin-C/etc/thin/mysite.ymlrestartNginx将继续运行并代理请求。如果您将Nginx设置为使用多个上游服务器，例如server{listen80;server
鉴于我有以下迁移:Sequel.migrationdoupdoalter_table:usersdoadd_column:is_admin,:default=>falseend#SequelrunsaDESCRIBEtablestatement,whenthemodelisloaded.#Atthispoint,itdoesnotknowthatusershaveais_adminflag.#Soitfails.@user=User.find(:email=>"admin@fancy-startup.example")@user.is_admin=true@user.save!ende
我正在使用active_admin，我在Rails3应用程序的应用程序中有一个目录管理，其中包含模型和页面的声明。时不时地我也有一个类，当那个类有一个常量时，就像这样:classFooBAR="bar"end然后，我在每个必须在我的Rails应用程序中重新加载一些代码的请求中收到此警告:/Users/pupeno/helloworld/app/admin/billing.rb:12:warning:alreadyinitializedconstantBAR知道发生了什么以及如何避免这些警告吗？ 最佳答案 在纯Ruby中:classA
它不等于主线程的binding，这个toplevel作用域是什么？此作用域与主线程中的binding有何不同？>ruby-e'putsTOPLEVEL_BINDING===binding'false 最佳答案 事实是，TOPLEVEL_BINDING始终引用Binding的预定义全局实例，而Kernel#binding创建的新实例>Binding每次封装当前执行上下文。在顶层，它们都包含相同的绑定(bind)，但它们不是同一个对象，您无法使用==或===测试它们的绑定(bind)相等性。putsTOPLEVEL_BINDINGput
我可以得到Infinity和NaNn=9.0/0#=>Infinityn.class#=>Floatm=0/0.0#=>NaNm.class#=>Float但是当我想直接访问Infinity或NaN时:Infinity#=>uninitializedconstantInfinity(NameError)NaN#=>uninitializedconstantNaN(NameError)什么是Infinity和NaN？它们是对象、关键字还是其他东西？ 最佳答案 您看到打印为Infinity和NaN的只是Float类的两个特殊实例的字符串