线程之间的C++通信

C++ communication between threads

本文关键字：通信 C++ 之间 线程      更新时间：2023-10-16

我有几个类，每个类在不同的线程中打开不同的程序，并使用CreateProcess处理/保存有关它的信息（如果有更面向C++的方法可以做到这一点，请告诉我——我看了）。

某些类依赖于运行的其他程序之一。如果A停下来，B就必须停下来。我不久前编写了这段代码，当时我的解决方案是创建一个具有静态函数的类，该类运行各种程序和保持其"状态"的静态成员变量。我也在使用CreateThread。

回过头来看，这种方法似乎。。。看上去脆弱而笨拙。我不知道使用这样一个"静态类"是否是一种好的做法（尤其是回忆起初始化状态成员变量时有多尴尬）。我想让每个类都包含自己的run函数。然而，我正在考虑的问题是如何让B班知道A是否尴尬地停了下来。他们仍然需要知道如何了解彼此的状态。请注意，我想在这个返工中使用std::thread，并且我对多线程几乎没有经验。谢谢你的帮助。

在多进程应用程序中，您将使用管道/文件将信息从一个进程传输到另一个进程（甚至可能是子进程的返回值）。因此，也可以尝试共享内存，尽管这可能有点挑战性（如果你愿意，可以查看Boost.Interprocess）。

在多线程应用程序中，基本上可以使用相同的选项：

  • 您可以使用共享的内存（前提是同步访问）
  • 可以使用队列将信息从一个线程传递到另一个线程（例如使用管道）

所以实际上这两者非常相似。

根据Tony Hoare的建议，您通常应该通过通信进行共享，而不是通过共享进行通信，这意味着将队列/管道授予共享内存的特权；然而，对于一个布尔标志，共享内存可以更容易地放置：

void do_a(std::atomic_bool& done) {
     // do things
     done = true;
}
int main() {
    std::atomic_bool done = false;
    auto a = std::async(do_a, done);
    auto b = std::async([](std::atomic_bool& done) {
        while (not done) {
            std::cout << "still not done" << std::endl;
            sleep(1);
        }
    });
    // other stuff in parallel.
}

当然，您甚至可以将这个标志放在std::shared_ptr中，以避免悬挂引用的风险。

相关文章：