std::threads 构造函数参数错误

std::threads constructor argument error

本文关键字：错误 参数 threads std 构造函数      更新时间：2023-10-16

我不是一个好的C++程序员，但目前正在使用C++的一些功能来清理我的C代码的脏部分。g++编译器抱怨threads[i] = thread(split, i, sums[i], from, to, f, nThreads);。请帮我找到问题。

mjArray只是一个瘦的类，而不是 std：：vector，这在我的情况下太重了。

#include <cstdio>
#include <cmath>
#include <ctime>
#include <thread>
using namespace std;
template<typename T>
class mjArray {
private:
    T* _array;
    int _length;
public:
    mjArray(int length) {
        _array = new T[length];
        _length = length;
    }
    mjArray(int length, T val) {
        _array = new T[length];
        _length = length;
        for (int i = 0; i < length; ++i) {
            _array[i] = val;
        }
    }
    ~mjArray() {
        delete[] _array;
    }
    T& operator[](int i) {
        return _array[i];
    }
    int length() {
        return _length;
    }
};
void split(int n, double& sum, int from, int to, double (*f)(double), int nThreads) {
    for (int i = from + n; i <= to; i += nThreads) {
        sum += f(i);
    }
}
double sigma(int from, int to, double (*f)(double), int nThreads) {
    double sum = 0.0;
    mjArray<double> sums(nThreads, 0.0);
    mjArray<thread> threads(nThreads);
    for (int i = 0; i < nThreads; ++i) {
        threads[i] = thread(split, i, sums[i], from, to, f, nThreads);
    }
    for (int i = 0; i < nThreads; ++i) {
        threads[i].join();
        sum += sums[i];
    }
    return sum;
}
double f(double x) {
    return (4 / (8 * x + 1) - 2 / (8 * x + 4) - 1 / (8 * x + 5) - 1 / (8 * x + 6)) / pow(16, x);
}
int main(void) {
    for (int i = 1; i <= 4; ++i) {
        time_t start = clock();
        double pi = sigma(0, 1000000, f, i);
        time_t end = clock();
        printf("pi = %.10f; nThreads = %d; elapsed = %.3fsn", pi, i, (double)(end - start) / CLOCKS_PER_SEC);
    }
    return 0;
}

#include <functional>
threads[i] = thread(split, i, std::ref(sums[i]), from, to, f, nThreads);
//                            ~~~~~~~~^

理由：

std::thread存储传递给其构造函数的参数的衰减副本，然后std::move这些副本以初始化在该新线程中运行的函子对象的参数。在引用的情况下，这将失败，因为您无法使用 xvalue 初始化非 const 左值引用(double& split 函数期望的引用((更不用说它是一个与您传递给构造函数thread's完全不同的double实例(。

解决方案是使用从帮助程序函数返回std::reference_wrapper<T> std::ref这会将您的引用包装在可复制的对象中，从而成功地将您的引用传输到新创建的线程。

相关文章：