OpenMP：让线程执行for for colop

Question

我想运行以下内容：

for (int index = 0; index < num; index++)

我想用四个线程运行for循环，并按顺序执行线程：0,1,2,3,4,5,6,7,8， ETC... 也就是说，要使线程在index = n，（n+1），（n+2），（n+3）（在任何特定的有序中，但始终以这种模式），我希望index = 0,1,2，...（n-1）的迭代已经完成。 有办法这样做吗？在这里订购并不能真正起作用，因为使身体成为订购的部分基本上会为我删除所有并行性，而安排似乎不起作用，因为我不希望线程在线程上工作k-＆gt; k+index /4。 感谢您的帮助！

Answer 1

您可以使用它来做到这一点，而不是循环的平行线，而是一个平行的区域，该区域在内部管理自己的循环，以及一个障碍，以确保所有跑步线程在能够继续之前都达到了相同的点。示例：

#include <stdatomic.h>
#include <stdio.h>
#include <omp.h>

int main()
{
  atomic_int chunk = 0;
  int num = 12;
  int nthreads = 4;
  
  omp_set_num_threads(nthreads);
  
#pragma omp parallel shared(chunk, num, nthreads)
  {
    for (int index; (index = atomic_fetch_add(&chunk, 1)) < num; ) {
      printf("In index %d\n", index);
      fflush(stdout);
#pragma omp barrier

      // For illustrative purposes only; not needed in real code
#pragma omp single
      {
        puts("After barrier");
        fflush(stdout);
      }
    }
  }

  puts("Done");
  return 0;
}

一个可能的输出：

$ gcc -std=c11 -O -fopenmp -Wall -Wextra demo.c
$ ./a.out
In index 2
In index 3
In index 1
In index 0
After barrier
In index 4
In index 6
In index 5
In index 7
After barrier
In index 10
In index 9
In index 8
In index 11
After barrier
Done

Answer 2

我不确定我正确理解您的请求。如果我尝试总结一下我的解释方式，那将是：“我希望4个线程共享一个循环的迭代，并且总是在循环的连续4个迭代中最多运行4个线程”。

如果那是您想要的，那么这样的事情：

int nths = 4;
#pragma omp parallel num_thread( nths )
for( int index_outer = 0; index_outer < num; index_outer += nths ) {
    int end = min( index_outer + nths, num );
    #pragma omp for
    for( int index = index_outer; index < end; index++ ) {
        // the loop body just as before
    } // there's a thread synchronization here
}