以下代码:
#include <ppl.h>
int i;
vector<int> val(10),summ(10,0);
for(i=0;i<10;i++) val[i]=i;
parallel_for(0, 10, [&] (int y){
vector<int> vett(1000);
double vall=val[y];
for(i=0;i<vett.size();i++)
vett[i]=vall;
for(i=0;i<vett.size();i++)
summ[y]+=vett[i];
});
for(i=0;i<10;i++)
cout<<summ[i]<<endl;产生随机输出,如:0 1000 1468 204 3600 25 5898 7000 7456 1395
我想我应该使用“可组合的”,但我找到的关于它的文档并不是很好。你知道如何让这段代码正常工作吗?如果vett是一个二维向量呢?
既然我想学习并行计算,那么是否值得学习这个新的microsoft库,或者有更好的替代方案?
发布于 2012-02-14 22:18:00
代码的主要问题是i下标变量。它同时被多个并行任务和使用。混乱随之而来,也是导致结果不稳定的原因。最简单的解决方法是在lambda中声明循环,如下所示:
for(int i=0;i<vett.size();i++)
vett[i]=vall;
for(int i=0;i<vett.size();i++)
summ[y]+=vett[i];注意,每个循环索引都是在for循环初始化中声明的。这是一种更惯用的用法,可以在所有循环中使用,除非在循环结束后确实需要i的最终值。
发布于 2012-02-14 23:23:41
并行代码的一个很好的经验法则是最小化共享变量的数量。
因此,您永远不应该使用[&]作为parallel_for (或std::thread)的lambda捕获。只捕获需要共享的变量。
如果你这样做了,你就会发现这个问题,@Blastfurnace指出,即i是在所有工人之间共享的。
https://stackoverflow.com/questions/9269535
复制相似问题