c – unordered_map的OpenMP / __ gnu_parallel
作者:互联网
在我的代码中的某些时候,我必须对unordered_map中的所有元素进行操作.为了加速这个过程,我想使用openMP,但天真的方法不起作用:
std::unordered_map<size_t, double> hastTable;
#pragma omp for
for(auto it = hastTable.begin();
it != hastTable.end();
it ++){
//do something
}
原因是,unordered_map的迭代器不是随机访问迭代器.
作为替代方案,我尝试了使用for_each的__gnu_parallel指令.但是下面的代码
#include <parallel/algorithm>
#include <omp.h>
__gnu_parallel::for_each (hashTable.begin(), hashTable.end(),[](std::pair<const size_t, double> & item)
{
//do something with item.secon
});
编译(gcc 4.8.2)
g++ -fopenmp -march=native -std=c++11
没有并行运行.使用向量切换unordered_map并使用相同的__gnu_parallel指令并行运行.
为什么在无序地图的情况下不能并行运行?有变通方法吗?
在下面我给你一些简单的代码,它可以重现我的问题.
#include <unordered_map>
#include <parallel/algorithm>
#include <omp.h>
int main(){
//unordered_map
std::unordered_map<size_t, double> hashTable;
double val = 1.;
for(size_t i = 0; i<100000000; i++){
hashTable.emplace(i, val);
val += 1.;
}
__gnu_parallel::for_each (hashTable.begin(), hashTable.end(),[](std::pair<const size_t, double> & item)
{
item.second *= 2.;
});
//vector
std::vector<double> simpleVector;
val = 1.;
for(size_t i = 0; i<100000000; i++){
simpleVector.push_back(val);
val += 1.;
}
__gnu_parallel::for_each (simpleVector.begin(), simpleVector.end(),[](double & item)
{
item *= 2.;
});
}
我期待着你的回答.
解决方法:
您可以在存储桶索引的范围上拆分循环,然后创建一个用于处理元素的存储桶内迭代器. unordered_map具有.bucket_count()和允许这样的特定于桶的迭代器开始(bucket_number),end(bucket_number).假设您没有从1.0修改默认的max_load_factor()并且具有合理的散列函数,那么您将平均每个桶1个元素,并且不应该浪费太多时间在空桶上.
标签:unordered-map,c,openmp,gnu-parallel 来源: https://codeday.me/bug/20190824/1713539.html