Несколько потоков к данным в массиве C ++

Question

Я использую цикл for для создания заданного количества потоков, каждый из которых составляет аппроксимацию части моего интеграла, я хочу, чтобы они вернули эти данные обратно в массив, чтобы позже я мог их суммировать (если я считаю правильнымЯ не могу просто сделать сумму + = в каждом потоке, потому что они будут сталкиваться), все работало правильно, до того момента, когда я хочу взять эти данные из каждого потока, я получаю ошибку:

calka.cpp:49:33: error: request for member 'get_future' in 'X', which is of non-class type 'std::promise<float>[(N + -1)]'

код:

#include <iostream> //cout  
#include <thread> //thread
#include <future> //future , promise
#include <stdlib.h> //atof
#include <string> //string
#include <sstream> //stringstream

using namespace std;

// funkcja 4x^3 + (x^2)/3 - x + 3
// całka x^4 + (x^3)/9 - (x^2)/2 + 3x 

void thd(float begin, float width, promise<float> & giveback)
{   
    float x = begin + 1/2 * width;
    float height = x*x*x*x + (x*x*x)/9 - (x*x)/2 + 3*x ; 
    float outcome = height * width;
    giveback.set_value(outcome);    

    stringstream ss;
    ss << this_thread::get_id();
    string output = "thread #id: " + ss.str() + "  outcome" + to_string(outcome);

    cout << output << endl;

}

int main(int argc, char* argv[])
{

    int sum = 0;
    float begin = atof(argv[1]);
    float size = atof(argv[2]);
    int N = atoi(argv[3]);
    float end = begin + N*size;

    promise<float> X[N-1];



    thread t[N];

    for(int i=0; i<N; i++){
        t[i] = thread(&thd, begin, size, ref(X[i]));
        begin += size;
    }

    future<float> wynik_ftr = X.get_future();
    float wyniki[N-1];

    for(int i=0; i<N; i++){
        t[i].join();
        wyniki[i] = wynik_ftr.get();
    }
    //place for loop adding outcome from threads to sum
    cout << N;

    return 0;
}

Answer 1

Не используйте VLA - promise<float> X[N-1]. Это расширение некоторых компиляторов, поэтому ваш код не переносим. Вместо этого используйте std::vector.

Кажется, вы хотите разделить вычисления интеграла на потоки N. Вы создаете N-1 фоновые потоки, и один вызов thd выполняется из потока main. В main вы объединяете все результаты, поэтому вам не нужно создавать wyniki как массив для хранения результата для потока, потому что вы собираете эти результаты последовательно - внутри цикла for в функции main. Поэтому достаточно одной float wyniki переменной.

Необходимо выполнить следующие шаги:

• подготовить N обещаний

• запускает N-1 потоки

• вызов thd из основного

• присоединение и добавление результатов из потоков N-1 в цикл

• присоединиться и добавить результат основного потока

Код:

std::vector<promise<float>> partialResults(N);

std::vector<thread> t(N-1);

for (int i = 0; i<N-1; i++) {
    t[i] = thread(&thd, begin, size, ref(partialResults[i]));
    begin += size;
}

thd(begin,size,ref(partialResults[N-1]));
float wyniki = 0.0f;
for (int i = 0; i<N-1; i++) {
    t[i].join();
    std::future<float> res = partialResults[i].get_future();
    wyniki  += res.get();
}
std::future<float> res = partialResults[N-1].get_future(); // get res from main
wyniki += res.get();

cout << wyniki << endl;