2

我正试图让 MPI 断开一个通信器,这是一个易怒的业务 - 我在下面整理了一个演示。我有两个版本的相同想法,监听一个 int,一个使用 MPI_IRecv,一个使用 boost::mpi::request。

在此程序上使用 mpiexec -n 2 时,您会注意到版本 A 会愉快地断开连接并退出,但版本 B 不会。MPI_Request_free-ing 一个 boost::mpi::request 有什么技巧吗?这似乎就是这里的区别。如果重要的话,我正在使用 MSVC 和 MSMPI,以及 Boost 1.62。

#include "boost/mpi.hpp"
#include "mpi.h"

int main()
{
    MPI_Init(NULL, NULL);
    MPI_Comm regional;
    MPI_Comm_dup(MPI_COMM_WORLD, &regional);
    boost::mpi::communicator comm = boost::mpi::communicator(regional, boost::mpi::comm_attach);
    if (comm.rank() == 1)
    {
        int q;

        //VERSION A:
//      MPI_Request n;
//      int j = MPI_Irecv(&q, 1, MPI_INT, 1, 0, regional, &n);
//      MPI_Cancel(&n);
//      MPI_Request_free(&n);

        //VERSION B:

//      boost::mpi::request z = comm.irecv<int>(1, 0, q);
//      z.cancel();

    }
    MPI_Comm_disconnect(&regional);
    MPI_Finalize();
    return 0;
}

我发现错误了吗?我怀疑我对代码很深。

4

1 回答 1

1

好吧,如果它被记录在案,它猜这不是一个错误:MPI_Request_freeBoost.MPI 不支持

现在回到 MPI 本身:

调用MPI_CANCEL标记取消挂起的非阻塞通信操作(发送或接收)。取消呼叫是本地的。它会立即返回,可能在实际取消通信之前。在调用. MPI_REQUEST_FREE_ MPI_WAIT_ 如果一个通信被标记为取消,那么对该通信的调用保证返回,而不管其他进程的活动(即,表现为一个本地函数);MPI_TESTMPI_CANCELMPI_WAITMPI_WAIT

这意味着,只是:

z.cancel();
z.wait();

你应该没事。

现在,恕我直言,这是 Boost.MPI 对适当 RAII 的严重浪费。

于 2017-05-19T21:25:04.327 回答