c++ - MPI_Irecv 没有收到循环后发送的消息

Question

我一直在并行执行哲学家就餐问题，但遇到了一个我无法解决的问题。基本上，我有一个 for 循环，其中一个进程检查是否有任何新消息，然后休眠半秒钟(它重复随机次数)。在该部分之后，它会尝试收集所有需要的 fork 以启动程序的“进食”部分。

问题是，出于某种原因，如果我从 for 循环内部发送 MPI 消息，目标进程会正常接收它，但如果我在循环之后发送消息，它就不会。让我展示一下它在代码中的样子，希望它能让事情更清楚一些:

for (int i = 0; i < think; i++) {
        Sleep(500);

        // Recieve messages
        MPI_Irecv(&rcv, 1, MPI_INT, MPI_ANY_SOURCE, NEED_FORK, MPI_COMM_WORLD, &req);
        MPI_Test(&req, &flag, &status);

        if(flag != 0) {
            // Do stuff
        }
        MPI_Send(&myid, 1, MPI_INT, target, NEED_FORK, MPI_COMM_WORLD); // He recieves this
    }
MPI_Send(&myid, 1, MPI_INT, target, NEED_FORK, MPI_COMM_WORLD); // He doesn't recieve this

问题是，出于某种原因，targert 进程没有接收到 for 循环结束后发送的任何消息，而它接收到循环之前或循环期间发送的任何消息。我真的不知道该怎么做才能完成这项工作，非常感谢任何帮助...

Answer 1

这是我对类似问题的回答。甚至代码看起来也很相似。 Infinite loop using MPI_Irecv and MPI_Test

请仔细查看在循环内调用 MPI_Test 和 MPI_Irecv。