C++ 中的类 Python 多处理

Question

我是 C++ 的新手，我来自 Python 的长期背景。

我正在寻找一种在 C++ 中并行运行函数的方法。我读了很多关于std::async 的文章，但对我来说仍然不是很清楚。

1. 下面的代码做了一些非常有趣的事情

   #include <future>
   #include <iostream>
   
   void called_from_async() {
     std::cout << "Async call" << std::endl;
   }
   
   int main() {
     //called_from_async launched in a separate thread if possible
     std::future<void> result( std::async(called_from_async));
   
     std::cout << "Message from main." << std::endl;
   
     //ensure that called_from_async is launched synchronously
     //if it wasn't already launched
     result.get();
   
     return 0;
   }
   

   如果我多次运行它，有时输出是我所期望的：

   Message from main.
   Async call
   

   但有时我会得到这样的结果：

   MAessysnacg ec aflrlom main.
   

   为什么cout 不先发生？我清楚地在cout 之后调用.get() 方法。

2. 关于并行运行。如果我有这样的代码：

   #include <future>
   #include <iostream>
   #include <vector>
   
   int twice(int m) {
     return 2 * m;
   }
   
   int main() {
     std::vector<std::future<int>> futures;
   
     for(int i = 0; i < 10; ++i) {
       futures.push_back (std::async(twice, i));
     }
   
     //retrive and print the value stored in the future
     for(auto &e : futures) {
       std::cout << e.get() << std::endl;
     }
   
     return 0;
   }
   

   对twice 函数的所有 10 次调用将同时在不同的内核上运行？

   如果没有，C++ 中是否有类似 Python multiprocess lib 的东西？

   主要是我正在寻找的：

   我编写了一个函数，并使用 n 个输入调用它？多处理？它会同时在n个节点上运行该函数1次。

Answer 1

1) result.get(); 不启动线程。它只等待结果。并行线程通过std::async(called_from_async) 调用（或编译器决定时）启动。

但是std::cout 保证是内部线程安全的。因此，您向我们展示的结果不应该发生。有一个竞争条件，但你不能像那样混合两个输出。如果真的发生了（我怀疑），那么您可能正在处理编译器错误。

2) 您的调用将并行运行。它取决于您机器上运行的操作系统和其他进程的核心数。但是很有可能会使用所有内容（假设您可以控制整个生态系统并且没有其他 CPU 密集型进程在后台运行）。

C++ 没有类似多处理的库（至少在 std 中没有）。如果您希望运行子流程，那么有几个选项，例如分叉或popen 系统调用。