如何在 VC++ 中使用多核计算进行循环？

Question

不知道多核并行化。但是对于简单的循环，它可能几乎没有修改。对于以下示例，如何在 VC++ 中使用多核计算进行简单循环？

#include <iostream>
#include <vector>
#include <ctime>
using namespace std;

void foo(int n, double* a, double* b, double *c, double*d, double* e, double* f, double* g)
{
    for (int i = 0; i < n; ++i)
    {
        a[i] = b[i] * a[i] + c[i] * (d[i] + e[i] + f[i] + g[i]);
    }
}

int main()
{
    int m = 1001001;
    vector<double> a(m), b(m), c(m), d(m), f(m);

    std::clock_t startcputime = std::clock();
    for (int i = 0; i < 1000; ++i)
        foo(1000000, &a[0], &b[0], &c[0], &d[0], &d[1], &f[0], &f[1000]);
    double cpu_duration = (std::clock() - startcputime) / (double)CLOCKS_PER_SEC;
    std::cout << "Finished in " << cpu_duration << " seconds [CPU Clock] " << std::endl;
}

Answer 1

concurrencyParallel Patterns Library（VC++ 的一部分）中的命名空间包含parallel_for的正是您想要的。

void parallel_foo(int n, double* a, double* b, double *c, double*d, double* e, double* f, double* g)
{
    concurrency::parallel_for(static_cast<size_t>(0), static_cast<size_t>(n), [&](size_t i) {
        a[i] = b[i] * a[i] + c[i] * (d[i] + e[i] + f[i] + g[i]);
    });
}

我建议使用size_t'n'。这样它就变得更干净了：

void parallel_foo(size_t n, double* a, double* b, double *c, double*d, double* e, double* f, double* g)
{
    concurrency::parallel_for(0, n, [&](size_t i) {
        a[i] = b[i] * a[i] + c[i] * (d[i] + e[i] + f[i] + g[i]);
    });
}

您还应该查看msdn上的示例

您可以使用“amp”作为替代。它更强大，更复杂。