快捷導(dǎo)航

C++異步數(shù)據(jù)交換實(shí)現(xiàn)方法介紹

更新時(shí)間：2022年11月20日 09:13:22 作者：無水先生

這篇文章主要介紹了C++異步數(shù)據(jù)交換實(shí)現(xiàn)方法，異步數(shù)據(jù)交換，除了阻塞函數(shù) send() 和 recv() 之外，Boost.MPI 還支持與成員函數(shù) isend() 和 irecv() 的異步數(shù)據(jù)交換

異步數(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ù)。不同之處在于，當(dāng) irecv() 返回時(shí)，無法保證在 s 中已收到數(shù)據(jù)。

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

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

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

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

#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() 來檢測(cè)異步操作何時(shí)完成。但是，您也可以像示例 47.8 中那樣調(diào)用阻塞函數(shù) boost::mpi::wait_all()。 boost::mpi::wait_all() 是一個(gè)阻塞函數(shù)，但好處是可以等待多個(gè)異步操作完成。 boost::mpi::wait_all() 在它等待的所有異步操作都已完成時(shí)返回。

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

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

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

到此這篇關(guān)于C++異步數(shù)據(jù)交換實(shí)現(xiàn)方法介紹的文章就介紹到這了,更多相關(guān)C++異步數(shù)據(jù)交換內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: