C++怎么實現異步數據交換

本篇內容介紹了“C++怎么實現異步數據交換”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

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

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

#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 使用阻塞函數 send() 發送字符串“Hello, world!”但是，數據是通過異步函數 irecv() 接收的。此成員函數需要與 recv() 相同的參數。不同之處在于，當 irecv() 返回時，無法保證在 s 中已收到數據。

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

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

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

示例 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);
  }
}

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

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

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

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

“C++怎么實現異步數據交換”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！