在不同的通信器中收到 MPI 消息

Question

据我了解，MPI 传播者限制了传播范围，例如 从一个通信器发送的消息永远不会在另一个通信器中接收。

但是，下面内联的程序似乎与此相矛盾。

我知道MPI_Send 调用会在匹配接收发布之前返回，因为它在后台进行了内部缓冲（与MPI_Ssend 不同）。我也知道MPI_Comm_free 不会立即销毁通信器，而只是将其标记为释放并等待任何待处理的操作完成。我想我不匹配的发送操作将永远挂起，但是我想知道为什么相同的对象（整数值）会被第二个通信器重用！？

这是正常行为，是 MPI 库实现中的错误，还是我的程序不正确？

非常感谢任何建议！

后期编辑：发布follow-up question

---

#include "stdio.h"
#include "unistd.h"
#include "mpi.h"

int main(int argc, char* argv[]) {
    int  rank, size;
    MPI_Group group;
    MPI_Comm my_comm;

    MPI_Init(&argc, &argv);

    MPI_Comm_rank(MPI_COMM_WORLD, &rank);
    MPI_Comm_size(MPI_COMM_WORLD, &size);
    MPI_Comm_group(MPI_COMM_WORLD, &group);

    MPI_Comm_create(MPI_COMM_WORLD, group, &my_comm);
    if (rank == 0) printf("created communicator %d\n", my_comm);

    if (rank == 1) {
        int msg = 123;
        MPI_Send(&msg, 1, MPI_INT, 0, 0, my_comm);
        printf("rank 1: message sent\n");
    }

    sleep(1);
    if (rank == 0) printf("freeing communicator %d\n", my_comm);
    MPI_Comm_free(&my_comm);

    sleep(2);

    MPI_Comm_create(MPI_COMM_WORLD, group, &my_comm);
    if (rank == 0) printf("created communicator %d\n", my_comm);

    if (rank == 0) {
        int msg;
        MPI_Recv(&msg, 1, MPI_INT, 1, 0, my_comm, MPI_STATUS_IGNORE);
        printf("rank 0: message received\n");
    }

    sleep(1);
    if (rank == 0) printf("freeing communicator %d\n", my_comm);
    MPI_Comm_free(&my_comm);

    MPI_Finalize();
    return 0;
}

输出：

created communicator -2080374784
rank 1: message sent
freeing communicator -2080374784
created communicator -2080374784
rank 0: message received
freeing communicator -2080374784

Answer 1

您看到的数字只是通讯器的句柄。释放手柄后，可以安全地重复使用它。至于为什么你能够发送消息，看看你是如何创建通信器的。当您使用 MPI_Comm_group 时，您将获得一个包含与指定通信器关联的等级的组。在这种情况下，您将获得所有排名，因为您获得的是 MPI_COMM_WORLD 的组。然后，您将使用 MPI_Comm_create 创建基于一组等级的通信器。您正在使用刚刚获得的同一组，其中将包含所有等级。因此，您的新通信器具有 MPI_COMM_WORLD 的所有等级。如果您希望您的通信器仅包含等级的子集，则需要使用不同的函数（或多个函数）来创建所需的组。我建议通读 MPI 标准的第 6 章，它包含您需要的所有功能。选择你需要什么来构建你想要的沟通器。