Распараллеливание цикла

@Vadim551 · Регистрация: 10.12.2018

есть цикл

C++

for (unsigned n = 0; n < threads; n++)
        {
            func (sigma, sub_noisy[n], sub_basic[n], sub_denoised[n],
                              w_table[n], h_table[n], chnls, nWien, kWien, NWien, pWien,
                              useSD_w, color_space, tau_2D_wien, &plan_2d_for_1[n],
                              &plan_2d_for_2[n], &plan_2d_inv[n]);
        }

как его распараллелить, желательно не используя openMP

@lArtl · 13.12.2018, 16:11

вообще не знаю, что под функцией func, но

C++

#include <future>
....
for (unsigned n = 0; n < threads; n++)
{
    std::async(std::launch::async, func, sigma, sub_noisy[n], sub_basic[n], sub_denoised[n],
        w_table[n], h_table[n], chnls, nWien, kWien, NWien, pWien,
        useSD_w, color_space, tau_2D_wien, &plan_2d_for_1[n],
        &plan_2d_for_2[n], &plan_2d_inv[n]);
}

Не проверял. Если что то серьезное, лучше использовать тред пул

@Vadim551 · 13.12.2018, 19:39 **[ТС]**

пробовал сделать так, используя ppl

C++

     parallel_for (0,threads,[&sub_noisy,&sub_basic,& w_table,&h_table,&plan_2d_for_1,&plan_2d_for_2,&plan_2d_inv](unsigned n)                                           
        {
       bm3d_1st_step(sigma, sub_noisy[n], sub_basic[n], w_table[n],
                              h_table[n], chnls, nHard, kHard, NHard, pHard, useSD_h,
                              color_space, tau_2D_hard, &plan_2d_for_1[n],
                              &plan_2d_for_2[n], &plan_2d_inv[n]);
       
        });

ругается на
1>D:\исхoдники\bm3d.cpp(103): error C3493: "sigma" нельзя передать неявно, поскольку не задан режим передачи по умолчанию
1>D:\исхoдники\bm3d.cpp(104): error C3493: "chnls" нельзя передать неявно, поскольку не задан режим передачи по умолчанию
1>D:\исхoдники\bm3d.cpp(104): error C3493: "nHard" нельзя передать неявно, поскольку не задан режим передачи по умолчанию
1>D:\исхoдники\bm3d.cpp(104): error C3493: "kHard" нельзя передать неявно, поскольку не задан режим передачи по умолчанию
1>D:\исхoдники\bm3d.cpp(104): error C3493: "NHard" нельзя передать неявно, поскольку не задан режим передачи по умолчанию
1>D:\исхoдники\bm3d.cpp(104): error C3493: "pHard" нельзя передать неявно, поскольку не задан режим передачи по умолчанию
1>D:\исхoдники\bm3d.cpp(104): error C3493: "useSD_h" нельзя передать неявно, поскольку не задан режим передачи по умолчанию
1>D:\исхoдники\bm3d.cpp(105): error C3493: "color_space" нельзя передать неявно, поскольку не задан режим передачи по умолчанию
1>D:\исхoдники\bm3d.cpp(105): error C3493: "tau_2D_hard" нельзя передать неявно, поскольку не задан режим передачи по умолчанию
может кто знает как исправить

@lArtl · 13.12.2018, 21:17

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

может кто знает как исправить

в лямбду this забыл передать.

@Vadim551 · 13.12.2018, 22:26 **[ТС]**

не совсем понял что нужно сделать

Добавлено через 15 минут

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

в лямбду this забыл передать.

не совсем понял что нужно сделать

@lArtl · 13.12.2018, 23:08

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

не совсем понял что нужно сделать

C++

parallel_for (0,threads,[this,&sub_noisy,&sub_basic,& w_table,&h_table,&plan_2d_for_1,&plan_2d_for_2,&plan_2d_inv](unsigned n)                                           
        {
       bm3d_1st_step(sigma, sub_noisy[n], sub_basic[n], w_table[n],
                              h_table[n], chnls, nHard, kHard, NHard, pHard, useSD_h,
                              color_space, tau_2D_hard, &plan_2d_for_1[n],
                              &plan_2d_for_2[n], &plan_2d_inv[n]);
       
        });

@Vadim551 · 13.12.2018, 23:41 **[ТС]**

1>D:\исхoдники\bm3d.cpp(101): error C3482: "this" может быть использован в качестве передаваемого параметра в лямбда-выражении только с нестатической функцией-членом

Добавлено через 3 минуты

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

C++

parallel_for (0,threads,[this,&sub_noisy,&sub_basic,& w_table,&h_table,&plan_2d_for_1,&plan_2d_for_2,&plan_2d_inv](unsigned n) 
{
bm3d_1st_step(sigma, sub_noisy[n], sub_basic[n], w_table[n],
 h_table[n], chnls, nHard, kHard, NHard, pHard, useSD_h,
 color_space, tau_2D_hard, &plan_2d_for_1[n],
 &plan_2d_for_2[n], &plan_2d_inv[n]);
});

1>D:\исхoдники\bm3d.cpp(101): error C3482: "this" может быть использован в качестве передаваемого параметра в лямбда-выражении только с нестатической функцией-членом

@lArtl · 14.12.2018, 02:44

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

1>D:\исхoдники\bm3d.cpp(101): error C3482: "this" может быть использован в качестве передаваемого параметра в лямбда-выражении только с нестатической функцией-членом

тогда попробуй так

C++

parallel_for (0,threads,[&](unsigned n)                                           
        {
       bm3d_1st_step(sigma, sub_noisy[n], sub_basic[n], w_table[n],
                              h_table[n], chnls, nHard, kHard, NHard, pHard, useSD_h,
                              color_space, tau_2D_hard, &plan_2d_for_1[n],
                              &plan_2d_for_2[n], &plan_2d_inv[n]);
       
        });

@Vadim551 · 14.12.2018, 07:33 **[ТС]**

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

тогда попробуй так

так в самом начале пробовал
1>D:\исхoдники\bm3d.cpp(108): error C2661: run_bm3d::<lambda_b051773df5291d01ebf876aa4193e98e >::<lambda_b051773df5291d01ebf876aa4193e98e>: нет перегруженной функции, принимающей 16 аргументов
1>D:\исхoдники\bm3d.cpp(108): error C2780: void Concurrency:: parallel_for(_Index_type,_Index_type,const _Function &,Concurrency::affinity_partitioner &): требует аргументов: 4, имеется: 3
1> C:\Program Files (x86)\Microsoft Visual Studio 11.0\VC\include\ppl.h(3562): см. объявление "Concurrency:: parallel_for"
1>D:\исхoдники\bm3d.cpp(108): error C2780: void Concurrency:: parallel_for(_Index_type,_Index_type,const _Function &,const Concurrency::simple_partitioner &): требует аргументов: 4, имеется: 3
1> C:\Program Files (x86)\Microsoft Visual Studio 11.0\VC\include\ppl.h(3523): см. объявление "Concurrency:: parallel_for"
1>D:\исхoдники\bm3d.cpp(108): error C2780: void Concurrency:: parallel_for(_Index_type,_Index_type,const _Function &,const Concurrency::static_partitioner &): требует аргументов: 4, имеется: 3
1> C:\Program Files (x86)\Microsoft Visual Studio 11.0\VC\include\ppl.h(3484): см. объявление "Concurrency:: parallel_for"
1>D:\исхoдники\bm3d.cpp(108): error C2780: void Concurrency:: parallel_for(_Index_type,_Index_type,_Index_type,c onst _Function &): требует аргументов: 4, имеется: 3
1> C:\Program Files (x86)\Microsoft Visual Studio 11.0\VC\include\ppl.h(3406): см. объявление "Concurrency:: parallel_for"
1>D:\исхoдники\bm3d.cpp(108): error C2780: void Concurrency:: parallel_for(_Index_type,_Index_type,_Index_type,c onst _Function &,_Partitioner &&): требует аргументов: 5, имеется: 3
1> C:\Program Files (x86)\Microsoft Visual Studio 11.0\VC\include\ppl.h(3370): см. объявление "Concurrency:: parallel_for"

C++

#pragma omp parallel shared(sub_noisy, sub_basic, sub_denoised,  w_table,h_table, plan_2d_for_1, plan_2d_for_2, plan_2d_inv)
        {
            #pragma omp for schedule(dynamic) nowait
            for (unsigned n = 0; n < nb_threads; n++)
            {
                bm3d_2nd_step(sigma, sub_noisy[n], sub_basic[n], sub_denoised[n],
                              w_table[n], h_table[n], chnls, nWien, kWien, NWien, pWien,
                              useSD_w, color_space, tau_2D_wien, &plan_2d_for_1[n],
                              &plan_2d_for_2[n], &plan_2d_inv[n]);
            }
         }

c openmp все просто, вот так работает, а с ppl не совсем понятно

@lArtl 322 / 174 / 78 Регистрация: 09.10.2014 Сообщений: 809
	13.12.2018, 21:17	4
	Сообщение от Vadim551 может кто знает как исправить в лямбду this забыл передать. 0

@Vadim551 0 / 0 / 0 Регистрация: 10.12.2018 Сообщений: 8
	13.12.2018, 22:26 [ТС]	5
	не совсем понял что нужно сделать Добавлено через 15 минут Сообщение от lArtl в лямбду this забыл передать. не совсем понял что нужно сделать 0

Опции темы