異步數(shù)據(jù)交換，除了阻塞函數(shù) send() 和 recv() 之外，Boost.MPI 還支持與成員函數(shù) isend() 和 irecv() 的異步數(shù)據(jù)交換。名稱以 i 開頭，表示函數(shù)立即返回。

示例 47.7。使用 irecv() 異步接收數(shù)據(jù)

#include <boost/mpi.hpp>
#include <boost/serialization/string.hpp>
#include <string>
#include <iostream>
int main(int argc, char *argv[])
{
  boost::mpi::environment env{argc, argv};
  boost::mpi::communicator world;
  if (world.rank() == 0)
  {
    std::string s;
    boost::mpi::request r = world.irecv(boost::mpi::any_source, 16, s);
    if (r.test())
      std::cout << s << '\n';
    else
      r.cancel();
  }
  else
  {
    std::string s = "Hello, world!";
    world.send(0, 16, s);
  }
}

Example47.7

示例 47.7 使用阻塞函數(shù) send() 發(fā)送字符串“Hello, world!”但是，數(shù)據(jù)是通過異步函數(shù) irecv() 接收的。此成員函數(shù)需要與 recv() 相同的參數(shù)。不同之處在于，當 irecv() 返回時，無法保證在 s 中已收到數(shù)據(jù)。

irecv() 返回類型為 boost::mpi::request 的對象。您可以調(diào)用 test() 來檢查是否已收到數(shù)據(jù)。此成員函數(shù)返回一個布爾值。您可以根據(jù)需要隨時調(diào)用 test()。因為 irecv() 是一個異步成員函數(shù)，所以第一次調(diào)用可能會返回 false，而第二次調(diào)用會返回 true。這意味著異步操作在兩次調(diào)用之間完成。

示例 47.7 僅調(diào)用 test() 一次。如果在 s 中接收到數(shù)據(jù)，則將變量寫入標準輸出流。如果沒有收到數(shù)據(jù)，則使用 cancel() 取消異步操作。

如果多次運行示例 47.7，有時會出現(xiàn) Hello, world!顯示，有時沒有輸出。結(jié)果取決于是否在調(diào)用 test() 之前接收到數(shù)據(jù)。

示例 47.8。使用 wait_all() 等待多個異步操作

#include <boost/mpi.hpp>
#include <boost/serialization/string.hpp>
#include <string>
#include <iostream>
int main(int argc, char *argv[])
{
  boost::mpi::environment env{argc, argv};
  boost::mpi::communicator world;
  if (world.rank() == 0)
  {
    boost::mpi::request requests[2];
    std::string s[2];
    requests[0] = world.irecv(1, 16, s[0]);
    requests[1] = world.irecv(2, 16, s[1]);
    boost::mpi::wait_all(requests, requests + 2);
    std::cout << s[0] << "; " << s[1] << '\n';
  }
  else if (world.rank() == 1)
  {
    std::string s = "Hello, world!";
    world.send(0, 16, s);
  }
  else if (world.rank() == 2)
  {
    std::string s = "Hello, moon!";
    world.send(0, 16, s);
  }
}

您可以多次調(diào)用 boost::mpi::request 上的 test() 來檢測異步操作何時完成。但是，您也可以像示例 47.8 中那樣調(diào)用阻塞函數(shù) boost::mpi::wait_all()。 boost::mpi::wait_all() 是一個阻塞函數(shù)，但好處是可以等待多個異步操作完成。 boost::mpi::wait_all() 在它等待的所有異步操作都已完成時返回。

在示例 47.8 中，等級為 1 的進程發(fā)送“Hello, world!”以及排名 2 的過程“你好，月亮！”由于接收數(shù)據(jù)的順序無關(guān)緊要，因此排名為 0 的進程調(diào)用 irecv()。由于程序只會在所有異步操作完成并接收到所有數(shù)據(jù)時生成輸出，因此類型 boost::mpi::request 的返回值被傳遞給 boost::mpi::wait_all()。因為 boost::mpi::wait_all() 需要兩個迭代器，所以 boost::mpi::request 類型的對象存儲在一個數(shù)組中。開始和結(jié)束迭代器被傳遞給 boost::mpi::wait_all()

Boost.MPI 提供了額外的函數(shù)，您可以使用它們來等待異步操作的完成。 boost::mpi::wait_any() 在恰好一個異步操作完成時返回，boost::mpi::wait_some() 在至少一個異步操作完成時返回。這兩個函數(shù)都返回一個 std::pair 指示哪個或哪些操作已完成。

boost::mpi::test_all()、boost::mpi::test_any() 和 boost::mpi::test_some() 通過一次調(diào)用測試多個異步操作的狀態(tài)。這些函數(shù)是非阻塞的并立即返回。