3

使用std::async我想知道是否有可能有一个辅助函数，它std::future从集合中创建 s （每个集合元素都有一个未来）。

我经常有以下情况：

auto func = []( decltype(collection)::reference value ) {
  //Some async work
};

typedef std::result_of<decltype(func)>::type ResultType;
std::vector<std::future<ResultType>> futures;
futures.reserve(collection.size());

// Create all futures
for( auto& element : collection ) {
  futures.push_back(std::async(func, element));
}

// Wait till futures are done
for( auto& future : futures ) {
  future.wait();
}

为了能够轻松地重用它，我想出了以下部分代码：

template< class Function, class CT, class... Args>
std::vector<std::future<typename std::result_of<Function(Args...)>::type>>
async_all( Function&& f, CT& col ) {

    typedef typename std::result_of<Function(Args...)>::type ResultType;
    std::vector<std::future<ResultType>> futures;
    futures.reserve(collection.size());

    for( auto& element : collection ) {
        futures.push_back(std::async(func, element));
    }
}
return futures;

现在我必须解决这个Args问题，因为async_all,Args不能再推导出来了。我目前唯一能想到的是另一个仿函数，它将集合中的元素转换为Args. 有没有更优雅的解决方案？

4

1 回答 1

3

您快到了。传递给的集合async_all包含我们唯一确定函数参数类型所需的所有信息；唯一的问题是如何提取这些信息。使用auto函数签名中的关键字，我们可以在函数参数之后写出返回类型。这不仅会产生更清晰的签名，而且还允许我们将参数值本身与decltype推导返回类型一起使用。例如：

template<typename F, typename CT>
auto reduce(F f, CT coll) -> decltype(f(*begin(coll), *begin(coll));

当然，还有其他方法可以确定提供的函数的参数类型（使用带有模板的函数签名推导）。但是，对于涉及重载函数和/或模板化函数对象的情况，这些方法可能会失败。

以下代码在 gcc 4.8 下编译并正常运行（打印“x=1”10 次）（早期版本应该可以正常工作）。注意我们甚至不必明确提及std::future：我们可以直接在std::async语句上使用 decltype 来推断它的类型。

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

template<class Function, class CT>
auto async_all(Function f, CT col)
    -> std::vector<decltype(std::async(f, *std::begin(col)))>
{
    std::vector<decltype(std::async(f, *std::begin(col)))> futures;
    futures.reserve(col.size());

    for (auto& element : col) {
        futures.push_back(std::async(f, element));
    }
    return futures;
}

int main()
{
    using namespace std;
    for (auto& f : async_all([](int x) { cout << "x = " << x << endl; }, 
                             vector<int>(10, 1)))
       f.get();
}

（async_all这里只计算一次，因为规范保证基于范围的 for 循环中的范围表达式）

于 2012-06-05T18:58:22.900 回答