1

我一直在对哲学家就餐问题进行并行实现，但遇到了一个我无法解决的问题。基本上，我有一个 for 循环，其中一个进程检查任何新消息，然后休眠半秒（它重复这个随机次数）。在该部分之后，它会尝试收集所有需要的分叉，以便开始程序的“吃”部分。

问题是，由于某种原因，如果我从 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

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

4

1 回答 1

0

这是我对类似问题的回答。甚至代码看起来也很相似。 使用 MPI_Irecv 和 MPI_Test 的无限循环

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

于 2013-07-09T15:30:19.390 回答