MPI 中的条件广播

Question

我想编写一个MPI程序，每个过程都有一个布尔值启动最初设置为false。然后，排名0检查大型2D布尔数组的值（i，j）是正确的 ture。如果启动的等级0的值是正确的，那么我希望等级0将启动的新值广播到其他过程，间接告诉他们每个过程以启动另一种方法的执行。

我该如何有效地做到这一点？很高兴听到任何想法。

- 谢谢

PS。我考虑过将2D布尔数组发送到每个过程，但是在某些情况下，2D阵列可以非常很大，我担心我的代码不会很好地扩展。

Answer 1

我假设您想利用等待时间。详细阐述 Gilles Gouaillardet 的评论，您可以构建一种“中断”类型的结构。

bool initiate = false;

if (rank == 0)
  for(int k = 0; k < I * J; k++)
    if(!bool_arr[k]) {
      initiate = true;
      break;
    }

MPI_Request request;
MPI_Ibcast(&initiate, 1, MPI_C_BOOL, 0, MPI_COMM_WORLD, &request);

for (int iter = 0; iter < numiter; iter++) {

    ; // DO WHATEVER YOU WANT!

    // TEST IF THE BROADCAST COMPLETE ONCE IN A WHILE
    bool complete;
    MPI_Test(&request, &complete, MPI_STATUS_IGNORE);
    if (complete && initiate) {
      function();
      initiate = false; // Avoid calling function() twice
    }
}
// DO NOT MOVE ON WITHOUT WAITING FOR BROADCAST
MPI_Wait(&request, MPI_STATUS_IGNORE);
if (initiate)
  function();