使用 C++11 的可变数量的异步线程

Question

我正在开发一个我想在循环中使用异步的程序。在我包含的示例代码中，只有 10 个元素，因此我可以轻松地为每个元素创建一个显式变量。但是，在我的主程序中，向量中的元素数量可能会有所不同。理想情况下，我想创建一个异步线程向量 - 数组中的每个元素一个 - 在我循环时被推回异步向量。然后我想等待它们全部完成，然后使用“ get()" 返回所有输出。

下面的代码将通过为每个线程分配一个显式变量来调用 async，但是有谁知道如何在向量中动态调用 async 而不必显式地为其分配一个变量？理想情况下，我希望这个程序在每次循环时调用一次“std::cout”，而不是只调用一次。

#include <iostream>
#include <vector>
#include <string>
#include <future>

std::string hi (std::string input)
{
    return "hello, this is " + input;
}

int main()
{
    std::vector<std::string> test_vector( 10, "a test" );
    std::future<std::string> a;
    std::future<std::string> b;

    for ( int i = 0; i < test_vector.size ( ); i++ )
    {
        a = std::async(std::launch::async, hi, test_vector[i]);
    }

    std::cout << a.get() << std::endl;

    return 0;
 }

Answer 1

如果我理解正确，可能是这样的：

std::vector<std::future<std::string>> vessel;
for ( int i = 0; i < test_vector.size ( ); i++ )
{
    std::future<std::string> aux;
    aux = std::async(std::launch::async, hi);
    vessel.push_back(aux);
}

抱歉，我不能作为评论发表，但这种方式取决于逻辑，如果它有效，那么您应该能够动态操作矢量vessel。

---

更新

更好：

vessel.push_back(new std::future<std::string>);
vessel[vessel.size()-1] = std::async(std::launch::async, hi);

这样你就不需要显式声明一个变量。但是你必须在完成后delete：

for(int i=0; i<(int) vessel.size(); i++)
{
    delete vessel[i];
}

Answer 2

答案包括std::cout：

std::vector<std::future<std::string>> a;
for (int i = 0; i < 10; ++i) {
  a.emplace_back(std::async(hi));
}
for (auto& element : a) {
  std::cout << element.get() << std::endl;
}

Answer 3

您可以通过创建一个期货向量来匹配您的线程向量来解决这个问题，如下所示：

#include <iostream>
#include <vector>
#include <string>
#include <future>

std::string hi(const std::string& input)
{
    return "hello, this is " + input;
}

int main()
{
    std::vector<std::string> tests = {"one", "two", "three", "four"};
    std::vector<std::future<std::string>> futures;

    // add the futures to the futures vector as you launch
    // your asynchronous functions
    for(auto&& t: tests)
        futures.emplace_back(std::async(std::launch::async, hi, std::cref(t)));

    // collect your results
    for(auto&& f: futures)
        std::cout << f.get() << '\n';
}

注意使用std::cref 来传递const 引用。使用std::ref 传递非 const 引用。