#pragma omplush 使线程之间交换数据

Question

您好，编写了一个非常简单的示例，介绍如何在生产者-> 中使用 omplush 交换数据。消费者方式，在线程中我发现了一个有趣的行为。

int a=-1;
int flag=1;
int count=0;
#pragma omp parallel  num_threads(2)
{ 
    int TID;
    TID=omp_get_thread_num();
#pragma omp sections 
    {

#pragma omp section /////////// Producer
        {

            for(int i=0; i<9;i++)
            {
                a=i;
#pragma omp flush(a)
                flag=1;
                printf("Producer a: %d  flag:%d  TID %d \n",a,flag,TID);

                while(flag)
                {

#pragma omp flush(flag)

                }

            }
            flag=2;
#pragma omp flush(flag)

        } // end producer

#pragma omp section  /////////// Consumer
        {
            while(1) {
                count++;

                flag=0;
                while(!flag)
                {
#pragma omp flush(flag)
                }
#pragma omp flush(a)
                printf("Consumer a: %d  Flag: %d  count %d TID %d \n",a,flag,count,TID);
                if (flag==2) break; // no more data

            } // end while(1)
        }// end consumer
    }// end sections

使用这个非常简单的代码将产生错误的输出： 生产者a：0标志：1 TID 0
生产者a：1标志：1 TID 0
消费者a：1标志：1计数1 TID 1
生产者a：2标志：1 TID 0
消费者a：2标志：1计数2 TID 1
生产者a：3标志：1 TID 0
消费者 a：3 标志：1 计数 3 TID 1
生产者a：4标志：1 TID 0
消费者 a：4 标志：1 计数 4 TID 1
生产者a：5标志：1 TID 0
消费者 a：5 标志：1 计数 5 TID 1
生产者a：6标志：1 TID 0
消费者 a：6 标志：1 计数 6 TID 1
生产者a：7标志：1 TID 0
消费者 a：7 标志：1 计数 7 TID 1
生产者a：8标志：1 TID 0
消费者a：8个标志：1计数8 TID 1
Consumer a: 8 Flag: 2 count 9 TID 1

错误是产生的第一个数据a=0被consumer忽略。 如果我简单地颠倒各部分的顺序，让生产者成为线程 1，那么一切都可以...... 生产者a：0标志：1 TID 1
消费者a：0标志：1计数1 TID 0
生产者a：1标志：1 TID 1
消费者a：1标志：1计数2 TID 0
.... 我的错是什么？

…… 在与 Ejd 进行有趣的讨论（谢谢）之后，代码被编辑为：

int a=-1;
int flag=0;
int count=0;
#pragma omp parallel  num_threads(2)
{ 
int TID;
TID=omp_get_thread_num();
#pragma omp sections 
{
#pragma omp section  /////////// Consumer
    {

        while(1) {
            count++;
            if (flag) printf("Consumer a: %d  Flag: %d  count %d TID %d \n",a,flag,count,TID);
            flag=0;
            while(!flag)
            {
#pragma omp flush(flag)
            }
            if (flag==2) break; // no more data

        } // end while(1)
    }// end consumer

#pragma omp section /////////// Producer
    {
        for(int i=0; i<9;i++)
        {
            a=i;
            printf("Producer a: %d  flag:%d  TID %d \n",a,flag,TID);
            flag=1;
            while(flag)
            {
#pragma omp flush(flag,a)
            }

        }
        flag=2;
#pragma omp flush(flag)

    } // end producer


}// end sections    

现在工作得很好。谢谢 ！

Answer 1

不幸的是，使用flush比乍一看要复杂得多。即使是 OpenMP 专家也很难正确使用它。问题的一部分是与列表刷新的定义错误。基本上它是允许移动的，所以如果你有一个以下形式的序列：

a = ...
#pragma omp flush(a)
b = ...
#pragma omp flush(b)

flush(a)必须在a的设置之后，但可以在set和flush(b)之后移动。它只需要在下次使用 a 之前发生。

在任何情况下，做你想做的事情的最好方法是使用没有列表的刷新，并在你感兴趣的每组变量之后执行刷新，并在读取之前执行刷新你感兴趣的每个变量。

另一个问题是你没有正确地传递。在消费者实际消费完所产生的值之前，您无法在消费者中为生产者设置标志来生成另一个数字。