2016-11-28 101 views
1

我正在研究使用OpenMP將順序程序轉換爲並行程序的n體分配。我有下面的函數可以在OpenMP關閉的情況下正常工作,但是會產生不正確的結果。我鎖定了循環內未更新的唯一變量。我一直盯着它很長一段時間,我不知道我做錯了什麼。任何提示將不勝感激。將c順序轉換爲OpenMP問題

void update() { 
    int i, j; 
    Body *tmp; 

    omp_lock_t lock; 
    omp_init_lock(&lock); 

    for (i=0; i<numBodies; i++) { 
    double x = bodies[i].x; 
    double y = bodies[i].y; 
    double vx = bodies[i].vx; 
    double vy = bodies[i].vy; 
    double ax = 0; 
    double ay = 0; 

    #pragma omp parallel for num_threads(4) 
    for (j=0; j<numBodies; j++) { 
     double r, mass, dx, dy, r_squared, acceleration; 

     if (j==i) continue; 
     dx = bodies[j].x - x; 
     dy = bodies[j].y - y; 
     mass = bodies[j].mass; 
     r_squared = dx*dx + dy*dy; 
     if (r_squared != 0) { 
     r = sqrt(r_squared); 
     if (r != 0) { 
      acceleration = K*mass/(r_squared); 
      omp_set_lock(&lock); 
      ax += acceleration*dx/r; 
      ay += acceleration*dy/r; 
      omp_unset_lock(&lock); 
     } 
     } 
    } 
    x += vx; 
    y += vy; 
    if (x>=x_max || x<x_min) x=x+(ceil((x_max-x)/univ_x)-1)*univ_x; 
    if (y>=y_max || y<y_min) y=y+(ceil((y_max-y)/univ_y)-1)*univ_y; 
    vx += ax; 
    vy += ay; 
    assert(!(isnan(x) || isnan(y))); 
    assert(!(isnan(vx) || isnan(vy))); 
    bodies_new[i].x = x; 
    bodies_new[i].y = y; 
    bodies_new[i].vx = vx; 
    bodies_new[i].vy = vy; 
    } 
    tmp = bodies; 
    bodies = bodies_new; 
    bodies_new = tmp; 
    omp_destroy_lock(&lock); 
} 
+1

爲什麼使用鎖?只要聲明'reduce(+:ax,ay)',那應該好多了(雖然我不確定這會解決你的問題,因爲我現在看不到這個問題有什麼問題)。 – Gilles

+0

您能否提供一個顯示使用OpenMP時出錯的[mcve]? – Zulan

+0

你會得到什麼,你期望什麼?我的意思是,如何將錯誤的值與那些正確的值比較 – Harald

回答

0

將編譯指示移至外部循環,刪除了減少並將I和j添加爲私有。