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);
}
爲什麼使用鎖?只要聲明'reduce(+:ax,ay)',那應該好多了(雖然我不確定這會解決你的問題,因爲我現在看不到這個問題有什麼問題)。 – Gilles
您能否提供一個顯示使用OpenMP時出錯的[mcve]? – Zulan
你會得到什麼,你期望什麼?我的意思是,如何將錯誤的值與那些正確的值比較 – Harald