可以 std::queue 在 OpenMP 中并发插入吗？答案

【问题标题】：Can std::queue concurrent insertion in OpenMP?可以 std::queue 在 OpenMP 中并发插入吗？
【发布时间】：2015-02-01 01:29:59
【问题描述】：

下面的这个短代码基于呼吸优先搜索。我希望将它与 OpenMP 并行，但没有成功。有没有办法让多个线程使用 OpenMP 并行结构将项目插入队列？

#include <omp.h>
#include <iostream>
#include <queue>

using namespace std;

int main(){

  queue<int> q;
  int v;
  int cnt = 0;

  for (int i =0; i<10; i++){
    q.push(i);
    cnt += 1;
  }

  while (!q.empty()) {
    v = q.front();
    q.pop();
    cout << "v=" << v << ",";

    #pragma omp parallel for
    for (int i = 1; i < 6; i++) {
      int j = v*i + 3;
      if ( j < 13) {
        q.push(j);
        cnt += 1;
      }
    }

  }

  cout << endl << q.size() << endl;
  cout << "count=" << cnt << endl;

  return 0;

}

【问题讨论】：

std::queue::push 不是线程安全的，所以队列不可能

标签： c++ multithreading queue openmp

【解决方案1】：

std::queue 可以在 OpenMP 中并发插入吗？

一般来说，没有。没有一个标准容器是安全的。您必须提供外部锁。

请参阅 Stack Overflow 上的相关问题：Are there any concurrent containers in C++11?。另请参阅工作组的 Concurrent Unordered Associative Containers for C++ 和 Stack Overflow 的 C++11 STL containers and thread safety。

【讨论】：