美文网首页
2020-04-02 openMP

2020-04-02 openMP

作者: Silly_N_Fool | 来源:发表于2020-04-02 20:49 被阅读0次
        int nthreads, tid;
         #pragma omp parallel private(nthreads, tid)
         {
     
             /* Obtain thread number */
             tid = omp_get_thread_num();
             printf("Hello World from thread = %d\n", tid);
     
             /* Only master thread does this */
             if (tid == 0)
             {
                 nthreads = omp_get_num_threads();
                 printf("Number of threads = %d\n", nthreads);
             }
    
        }  /* All threads join master thread and disband */  
    
        int x = 2;
        # pragma omp parallel num_threads(2) shared(x)
        {
            if (omp_get_thread_num() == 0){
                x = 5;
            }else{
                printf("1: Thread# %d: x = %d\n", omp_get_thread_num(),x);
            }
            #pragma omp barrier
            if (omp_get_thread_num() == 0){
                printf("2: Thread# %d: x = %d\n", omp_get_thread_num(),x);
            }else{
                printf("3: Thread# %d: x = %d\n", omp_get_thread_num(),x);
            }
        }
    
        int nthreads,tid,var3;
        var3=30;
        char buf[32];
    /* Fork a team of threads */
        #pragma omp parallel private(nthreads,tid) shared(var3)
        {
            tid= omp_get_thread_num(); /* Obtain and print thread id */
            printf("Hello, world from OpenMPthread %d, shared var=%d\n", tid,var3);
            if (tid== 0) /*Only master thread does this */
            {
                nthreads= omp_get_num_threads();
                printf(" Number of threads %d, shared var=%d\n",nthreads,var3);
            }
        }
    
    static long num_steps= 10000000;
    double step;
    #define NUM_THREADS 4
    int main(){    
        int i; 
        double x, pi, sum = 0.0, start_time,end_time;
        step = 1.0/(double) num_steps;
        start_time=clock();
        for (i=1;i<= num_steps; i++){
            x = (i-0.5)*step;
            sum = sum+ 4.0/(1.0+x*x);
        }
        pi = step * sum;
        end_time=clock();
        printf("Pi=%.10lf\nRunning time %d\n", pi, end_time-start_time);
    
        return 0;
    }
    
    static long num_steps= 100000;
    double step;
    #define NUM_THREADS 4
    int main(){
    
        int i ; 
        double pi, sum[NUM_THREADS] , start_time, end_time;
        step = 1.0/(double) num_steps;
        omp_set_num_threads(NUM_THREADS);
        start_time=omp_get_wtime();
        #pragma omp parallel
        {
            int id; double x;
            id = omp_get_thread_num();
            for (i=id, sum[id]=0.0; i< num_steps; i=i+NUM_THREADS){
                x = (i+0.5)*step; 
                sum[id] += 4.0/(1.0+x*x);
            }   
        }
        for (i=0, pi=0.0;i<NUM_THREADS;i++) {
            pi += sum[i] * step;
        } 
        end_time=omp_get_wtime();
        printf("Pi=%lf\nRunning time %d\n", pi, end_time-start_time);
    
        return 0;
    }
    
        int i,id; 
        double start_time, end_time;
        double x, pi, sum[NUM_THREADS];
        step = 1.0/(double) num_steps;
        omp_set_num_threads(NUM_THREADS);
        start_time=omp_get_wtime();
        #pragma omp  parallel private(x, id)
        {
            id = omp_get_thread_num(); sum[id] = 0;
            #pragma omp  for
            for (i=0;i< num_steps; i++){
            x = (i+0.5)*step;
            sum[id] += 4.0/(1.0+x*x);
            }
        }
        for(i=0, pi=0.0;i<NUM_THREADS; i++) pi += sum[i] * step;
        end_time=omp_get_wtime();
        printf("Pi=%lf\nRunning time %d\n", pi, end_time-start_time);
    

    要避免数据竞争就要声明私有变量
    局部变量都是私有的
    Pi的并行计算每个id占据一个数组位置,最后对数组进行累加

    相关文章

      网友评论

          本文标题:2020-04-02 openMP

          本文链接:https://www.haomeiwen.com/subject/ubvfphtx.html