您好,登錄后才能下訂單哦!
本篇內(nèi)容介紹了“C++怎么實(shí)現(xiàn)異步數(shù)據(jù)交換”的有關(guān)知識(shí),在實(shí)際案例的操作過程中,不少人都會(huì)遇到這樣的困境,接下來就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧!希望大家仔細(xì)閱讀,能夠?qū)W有所成!
異步數(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í),無(wú)法保證在 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ù)的順序無(wú)關(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ù)是非阻塞的并立即返回。
“C++怎么實(shí)現(xiàn)異步數(shù)據(jù)交換”的內(nèi)容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站,小編將為大家輸出更多高質(zhì)量的實(shí)用文章!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。