2011-12-22 92 views

回答

1

一个粗糙的方法是在OpenMP关键区域,在这里你们都设置了“已设置”标志和共享变量。当每个线程进入关键区域时,它会测试已设置的标志,并且

更细粒度的方法是使用OpenMP锁;你可以通过设置第一个线程锁定其他线程不能,并使用它作为你的标志:

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

void setonce_thread(omp_lock_t *l, int input, int *sharedvar) { 
    if (omp_test_lock(l)) { 
     printf("Set lock with %d\n", input); 
     *sharedvar = input; 
    } else { 
     printf("Could not set lock with %d\n", input); 
    } 
} 

void setonce_crit(int input, int *setflag, int *sharedvar) { 
#pragma omp critical 
    { 
     if ((*setflag) == 0) { 
      (*setflag)++; 
      *sharedvar = input; 
      printf("Set in crit with %d\n", input); 
     } else { 
      printf("Could not set in crit with %d\n", input); 
     } 
    } 
} 


int main() 
{ 
    omp_lock_t lck; 
    int sharedvar1, sharedvar2; 
    int setflag = 0; 
    int input = 17; 

    omp_set_nested(1); 
    omp_set_num_threads(9); 
    omp_init_lock(&lck); 
#pragma omp parallel shared(lck, sharedvar1, sharedvar2, setflag, input) default(none) num_threads(3) 
    { 
#pragma omp for 
     for (int i=0; i<3; i++) { 
#pragma omp parallel shared(lck, sharedvar1, sharedvar2, setflag, input) default(none) 
      { 
#pragma omp for 
       for (int j=0; j<3; j++) { 
        int id=omp_get_thread_num(); 
        setonce_thread(&lck, id, &sharedvar1); 
        setonce_crit(id, &setflag, &sharedvar2); 
       } 
      } 
     } 
     omp_unset_lock(&lck); 
    } 
    omp_destroy_lock(&lck); 

    printf("Shared Var 1 = %d\n", sharedvar1); 
    printf("Shared Var 2 = %d\n", sharedvar2); 
    printf("Set Flag  = %d\n", setflag); 
    return 0; 
} 
0

如果只写入每个进程一次,而不是每个线程一次,那么您不需要任何同步,因为没有任何同步。只要做好写保护。

+0

我认为OPs的问题是_how_安排每个进程只做一次。 – 2011-12-24 17:14:08