c - 如何使用 MPI_Abort() 终止其他处理器

Question

在 MPI 中，MPI_Abort() 主要用于中止异常行为。在下面的程序中，每次迭代时，ROOT 进程都会检查一个条件，而其余处理器则在 MPI_Barrier 处等待接收下一次迭代的数据。因此，如果满足阈值，我希望根终止整个循环并且其他处理器也应该离开循环并终止。我的问题是:使用 MPI_Abort() 以使在屏障中等待的处理器终止是否有意义？

void kmeans() {

    do{
        // Step1: ROOT Broadcast the K centroids.
        MPI_Bcast(&cluster_centroids, N, MPI_FLOAT, ROOT, MPI_COMM_WORLD);
        MPI_Barrier(MPI_COMM_WORLD);

        // Step2: Calculate the distances.
        points_assignment(data, cluster_center);

        // Step3: Update cluster centroid (Locally at each processor)
        update_centroids_locally();

        if(Rank == ROOT){
            // Step4: ROOT checks the threshold
            Flag = check_threshold(cluster_center);

            if(Flag == 1){
                // MPI_Abort(MPI_COMM_WORLD,0);
                break;
            }else{
                continue;
            }
        }

    } while(1);

}

Answer 1

为了避免使用MPI_Abort，我可以想到两种终止选项:

1)简单的:每次广播一个终止标志，每个进程将根据该标志继续或停止。

2) 您可以使用两个MPI_IBcast 和MPI_Waitany。使用一个MPI_IBcast，您将广播您的cluster_centroids，而使用另一个，您将广播终止标志。每次您将检查广播是否已完成，并基于此，每个进程将决定继续或停止。