C++ 程序意外阻塞/抛出

Question

我正在学习 C++ 中的互斥锁，但以下代码(摘自 N. Josuttis 的“C++ 标准库”)有问题。

我不明白为什么它会阻塞/抛出除非我在主线程中添加this_thread::sleep_for(然后它不会阻塞并且所有三个调用都是执行)。

编译器是从命令行使用的 cl.exe。

#include <future>
#include <mutex>
#include <iostream>
#include <string>
#include <thread>
#include <chrono>

std::mutex printMutex;

void print(const std::string& s)
{
    std::lock_guard<std::mutex> lg(printMutex);

    for (char c : s)
    {
        std::cout.put(c);
    }
    std::cout << std::endl;
}

int main()
{
    auto f1 = std::async(std::launch::async, print, "Hello from thread 1");
    auto f2 = std::async(std::launch::async, print, "Hello from thread 2");

    // std::this_thread::sleep_for(std::chrono::seconds(1));

    print(std::string("Hello from main"));       
}

Answer 1

我认为您看到的是 async(结合 future)的 MSVC 实现的一致性问题。我相信是not conformant .我能够使用 VS2013 重现它，但无法使用 gcc 重现该问题。

崩溃是因为主线程在其他两个线程完成之前退出(并开始清理)。

因此，两个 futures 上的简单延迟(sleep_for)或 .get() 或 .wait() 应该修复它你。所以修改后的 main 可能看起来像；

int main()
{
    auto f1 = std::async(std::launch::async, print, "Hello from thread 1");
    auto f2 = std::async(std::launch::async, print, "Hello from thread 2");

    print(std::string("Hello from main"));       

    f1.get();
    f2.get();
}

支持显式等待或克服定时“ sleep ”。

一致性说明

有来自 Herb Sutter 的提议更改等待或阻止从 async 返回的 future 的共享状态。这可能是 MSVC 行为的原因，它可以被视为已实现该提案。我不确定该提案的最终结果是什么，或者它与 C++14 的集成(或其中的一部分)是什么。至少 w.r.t.阻止从 async 返回的 future 看起来 MSVC 行为没有进入规范。

有趣的是，§30.6.8/5 中的措辞发生了变化；

来自 C++11

a call to a waiting function on an asynchronous return object that shares the shared state created by this async call shall block until the associated thread has completed, as if joined

到 C++14

a call to a waiting function on an asynchronous return object that shares the shared state created by this async call shall block until the associated thread has completed, as if joined, or else time out

我不确定如何指定“超时”，我想它是实现定义的。