Использование функтора в параллельных вычислениях

@Patifon_Kakao · Регистрация: 01.08.2015

Author24 — интернет-сервис помощи студентам

Имеется функтор, которых производит преобразование в потоках над элементами контейнера, например вектора. Очевидно, что использование мьютекса в функторе приведет к бесполезности использования потоков. Существует ли иное решение, кроме как, например, создать вектор функторов, и при запуске потока использовать элементы этого вектора? Без использования omp.

C++

#include <iostream>
 
#include <vector>
#include<thread>
 
class Square {
public:
    int operator() (const int value)
    {
        std::cout << "thread_id = "<< std::this_thread::get_id() << std::endl;
        return pow(value, 2);
    }
};
 
 
template <typename Iter, class Operation>
void calculation_in_threads(Iter  begin, Iter  end, Operation op)
{
 
    std::vector<std::thread> threads;
 
    for (; begin != end; ++begin)
    {
        std::thread th([begin, &op]
        {
            *begin = op(*begin);
        });
        threads.push_back(std::move(th));
    }
 
 
    for (std::thread & th : threads)
    {
        if (th.joinable())
            th.join();
    }
 
}
 
int main(int argc, char* argv[])
{
    std::vector<int> v(16);
    for (auto i = 0; i < v.size(); ++i)
        v[i] = i + 1;
 
    Square sq;
    calculation_in_threads(v.begin(), v.end(), sq);
 
    return 0;
}

@TheCalligrapher · 24.04.2020, 03:42

Сообщение от Patifon_Kakao

Очевидно, что использование мьютекса в функторе приведет к бесполезности использования потоков.

Так а откуда вообще возник вопрос? С чего вы взяли, что тут вообще нужна какая-то синхронизация? Где вы тут увидели конфликт по данным между потоками в само функторе?

@TheCalligrapher Вездепух 11696 / 6375 / 1724 Регистрация: 18.10.2014 Сообщений: 16,071
	24.04.2020, 03:42	2
	Сообщение от Patifon_Kakao Очевидно, что использование мьютекса в функторе приведет к бесполезности использования потоков. Так а откуда вообще возник вопрос? С чего вы взяли, что тут вообще нужна какая-то синхронизация? Где вы тут увидели конфликт по данным между потоками в само функторе? 0