C++17用futures并行生成直方图：如何将模板函数传给std::async？

核心错误原因 #

LocalSortHist是Histogram<T>类的非静态成员函数，调用这类函数时必须传入对应的类实例指针（也就是隐式的this参数），你之前的std::async调用没有传入实例，所以匹配失败。同时你编写的GetIndexes存在未初始化变量、边界计算错误的问题，也会导致运行异常。

修复步骤 #

1. 修正std::async调用写法 #

将创建异步任务的代码替换为以下内容，补全调用非静态成员函数需要的实例指针，同时匹配参数类型：

// 显式指定std::launch::async保证强制创建新线程，避免默认惰性求值导致无并行
auto future = std::async(std::launch::async, &Histogram<T>::LocalSortHist, this, data, static_cast<uint>(idxA), static_cast<uint>(idxB));

参数顺序说明：

• 第一个参数指定线程启动策略
• 第二个参数是成员函数指针的标准写法
• 第三个参数传入当前类实例的this指针，为成员函数提供调用上下文
• 后续参数按顺序传入LocalSortHist需要的入参，做类型转换匹配uint的参数要求

2. 修复GetIndexes函数的BUG #

原函数存在未初始化变量、边界计算错误会丢最后一个元素，修改后代码如下：

template <class T>
vector<int> Histogram<T>::GetIndexes(size_t size, int threadsCount)
{
    vector<int> pidx{};
    if (threadsCount <= 0 || size == 0) return pidx;
    // 避免线程数大于数据量的异常情况
    threadsCount = std::min(threadsCount, static_cast<int>(size));
    int w = static_cast<int>(size / threadsCount);
    int idx = 0; // 初始化变量避免未定义行为
    while(idx < static_cast<int>(size))
    {
        pidx.push_back(idx);
        idx += w;
    }
    // 最后一段直接补到size，不要用size-1，避免漏算最后一个元素
    if (pidx.back() != static_cast<int>(size))
        pidx.push_back(static_cast<int>(size));
    return pidx;
}

3. 修正结果归并的边界问题 #

原归并代码固定按threadsCount遍历，可能出现越界，修改为遍历futures本身的长度更稳妥：

// loop to collect threads results
for (auto& fu : futures)
{
    auto result = fu.get();
    for (size_t r = 0; r < BarCount; ++r)
        bars[r] += result[r];
}

可选优化 #

如果LocalSortHist仅依赖入参、BarCount和GetBarIndex，没有用到类的非静态成员，可以将LocalSortHist声明为静态成员函数，调用时就不需要传入this指针。

内容的提问来源于stack exchange，提问作者Soleil