c++ - 是否可以强制 MPI 在发送时始终阻塞？

Question

有没有办法强制 MPI 总是阻止发送？这在寻找分布式算法中的死锁时可能很有用，否则它取决于 buffering MPI might choose to do on send .

例如，下面的程序(运行 2 个进程)在我的机器上运行没有问题:

// C++
#include <iostream>
#include <thread>

// Boost
#include <boost/mpi.hpp>
namespace mpi = boost::mpi;

int main() {
    using namespace std::chrono_literals;

    mpi::environment env;
    mpi::communicator world;
    auto me = world.rank();
    auto other = 1 - me;

    char buffer[10] = {0};

    while (true) {
        world.send(other, 0, buffer);
        world.recv(other, 0, buffer);
        std::cout << "Node " << me << " received" << std::endl;

        std::this_thread::sleep_for(200ms);
    }
}

但如果我将缓冲区的大小更改为10000，它会无限期阻塞。

Answer 1

对于纯 MPI 代码，您所描述的正是 MPI_Ssend() 给您的。但是，在这里，您使用的不是纯 MPI，而是 boost::mpi。不幸的是，根据 boost::mpi's documentation , MPI_Ssend() 不受支持。

也就是说，也许 boost::mpi 提供了另一种方式，但我对此表示怀疑。