C++ 11并行执行

Question

首先我做了一个线程池，并试图对一个大小为40960个float元素的数组做一些重算术运算。

单线程方法得到0.0009秒的结果，而同时运行4线程的并行方法得到0.0003秒。在这个实现中，我手动将任务分配到4个部分，并将它们排入线程池。

现在我想为我的线程池提供一个通用方法parfor。我试过这个：

void parfor(int begin, int end, std::function<void(int)>func) 
    { 
     int delta = (end - begin)/M_count; 
     for (int i = 0; i < M_count; ++i) 
      queue([=]{ 
       int localbegin = begin + i*delta; 
       int localend = (i == M_count - 1) ? end : localbegin + delta; 
       for (int it = localbegin; it < localend; ++it) 
        func(it); 
      }); 
     wait(); 
    } 

其中M_count是线程数。执行时间变为0.003秒（大约是手工分发作业的10倍）。我想std ::函数有一个很好的运行时间开销，但不知道任何其他的替代方法。你能给我一些建议吗？非常感谢。

编辑： 根据Rapptz的建议，我尝试这样做：

template <typename Function> 
void parfor(int begin, int end, Function) 

，并用它是这样的：

pool.parfor(0, 40960, [&](int i){ 
    buff[i] = pow5(buff[i]); 
}); 

它显示了一些错误：

error C2371: 'it' : redefinition; different basic types 
error C2512: 'wmain::<lambda_badf06dfbebc4bb15b3ade2b922c7f76>' : no appropriate default constructor available 

我想它将lambda视为一种类型，但不知道如何解决它...

Answer 1

（太多评论...）这只是解释如何实现Rapptz使用模板参数来指定函数（因此可以内联）的建议。

考虑下面的代码：

#include <iostream> 

void f(int n) { std::cout << "f(" << n << ");\n"; } 
void g(int n) { std::cout << "g(" << n << ");\n"; } 

template <typename Function> 
void t(Function function, int n) 
{ 
    static int x; 
    std::cout << "&x " << &x << '\n'; 
    function(n); 
} 

struct FuncF { static void f(int n) { std::cout << "Ff(" << n << ");\n"; } }; 
struct FuncG { static void f(int n) { std::cout << "Gf(" << n << ");\n"; } }; 

template <typename Function> 
void ft(int n) 
{ 
    static int x; 
    std::cout << "&x " << &x << '\n'; 
    Function::f(n); 
} 

int main() 
{ 
    t(f, 42); 
    t(g, 42); 

    ft<FuncF>(42); 
    ft<FuncG>(42); 
} 

这将打印类似：

&x 00421760 
f(42); 
&x 00421760 
g(42); 
&x 00421764 
Ff(42); 
&x 00421768 
Gf(42); 

注意的是，前两个打印相同的地址x ...这是因为只有一个实例化的模板因为这两个调用的函数类型是相同的。 ft模板使用模板参数访问该函数而不涉及运行时函数参数，因此有两个实例产生本地静态的不同地址x。

要使您的函数调用内联，您应该采用类似于FuncF/FuncG和ft的方法。