代码之家 › 专栏 › 技术社区 › Michael

openmp并行循环的输出容器

openmp parallel-processing

Michael · 技术社区 · 7 年前

收集输出容器时,哪个临界截面样式更好?

// Insert into the output container one object at a time.
vector<float> output;
#pragma omp parallel for
for(int i=0; i<1000000; ++i)
{
    float value = // compute something complicated
    #pragma omp critical
    {
        output.push_back(value);
    }
}

// Insert object into per-thread container; later aggregate those containers.
vector<float> output;
#pragma omp parallel
{
    vector<float> per_thread;
    #pragma omp for
    for(int i=0; i<1000000; ++i)
    {
        float value = // compute something complicated
        per_thread.push_back(value);
    }
    #pragma omp critical
    {
        output.insert(output.end(), per_thread.begin(), per_thread.end());
    }
}

// Insert into the output container one object at a time.
vector<float> output;
#pragma omp parallel for
for(int i=0; i<1000000; ++i)
{
    int k = // compute number of items
    for( int j=0; j<k; ++j)
    {
        float value = // compute something complicated
        #pragma omp critical
        {
            output.push_back(value);
        }
    }
}

// Insert object into per-thread container; later aggregate those containers.
vector<float> output;
#pragma omp parallel
{
    vector<float> per_thread;
    #pragma omp for
    for(int i=0; i<1000000; ++i)
    {
        int k = // compute number of items
        for( int j=0; j<k; ++j)
        {
            float value = // compute something complicated
            per_thread.push_back(value);
        }
    }
    #pragma omp critical
    {
        output.insert(output.end(), per_thread.begin(), per_thread.end());
    }
}

1 回复 | 直到 7 年前

Zulan 7 年前

如果每次并行迭代都只插入一项,那么正确的方法是:

std::vector<float> output(1000000);
#pragma omp parallel for
for(int i=0; i<1000000; ++i)
{
    float value = // compute something complicated
    output[i] = value;
}

指定的不同元素是线程安全的 std::vector (这是有保证的,因为 i 是不同的)。在这种情况下,没有明显的虚假分享。

如果您没有在每个并行迭代中插入一个项目,那么两个版本基本上都是正确的。

您的第一个版本使用 critical 在循环中可能会非常慢-请注意,如果计算非常慢,则总体上可能仍然很好。

推荐文章

davidalayachew · 为什么我的文件有竞争条件,即使我使用了StandardOpenOption。同步?

1 年前

Anshuman Sinha · 使用OCR将多个img文件多重处理为文本

1 年前

Rishab · 在并行Java中运行函数

1 年前

Ahmed El-Gabbas · 在函数内运行时,仅将特定对象导出到处理节点

2 年前

Deep · 当您并行化代码时,如何保存两个独立的CSV?

2 年前

Setu · MPI代码的哪些部分是复制的,哪些是共享的?

2 年前

Alexander Obidiegwu · 多处理代码在while循环中不起作用

2 年前

heyula · 如何在mpi中定义本地数组?

2 年前

Rebel · 如何以最有效的方式加速和并行化以下matlab代码?

2 年前

Kaushik Ghosh · 最佳方法在PySpark中遍历数据帧的行

2 年前