c++ - 在 C++ OpenMP 中为每个线程定义一个优先级队列

Question

我在 OpenMP 中并行化一个 for 循环，我试图为每个线程创建一个优先级队列，这样我就可以更新与线程对应的优先级队列，所以我正在尝试这样的事情:

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

void test(){

  // I need a priority queue per thread
  // std::priority_queue<int> q_per_thread;

  # pragma omp parallel for num_threads(10)
  for(int i = 0; i < 100; i++){
      // push i to the queue corresponding to the thread
  }

}

这可能吗？

Answer 1

您需要一组优先级队列，因为您将在并行 OpenMP 部分中拥有多个线程:

 // I need a priority queue per thread
 std::vector<std::priority_queue<int>> q_per_thread(10);

 # pragma omp parallel for num_threads(10)
 for(int i = 0; i < 100; i++){
    // push i to the queue corresponding to the thread
    q_per_thread[omp_get_thread_num()].push(i);
 }

编辑:修复了它