C++中的std::async()詳解
1、std::async函數(shù)原型:
template<class Fn, class... Args> future<typename result_of<Fn(Args...)>::type> async(launch policy, Fn&& fn, Args&&...args);
功能:第二個參數(shù)接收一個可調(diào)用對象(仿函數(shù)、lambda表達(dá)式、類成員函數(shù)、普通函數(shù)......)作為參數(shù),并且異步或是同步執(zhí)行他們。
a、對于是異步執(zhí)行還是同步執(zhí)行,由第一個參數(shù)的執(zhí)行策略決定:
(1)、std::launch::async 傳遞的可調(diào)用對象異步執(zhí)行;
(2)、std::launch::deferred 傳遞的可調(diào)用對象同步執(zhí)行;
(3)、std::launch::async | std::launch::deferred 可以異步或是同步,取決于操作系統(tǒng),我們無法控制;
(4)、如果我們不指定策略,則相當(dāng)于(3)。
b、對于執(zhí)行結(jié)果:
我們可以使用get、wait、wait_for、wait_until等待執(zhí)行結(jié)束,區(qū)別是get可以獲得執(zhí)行的結(jié)果。如果選擇異步執(zhí)行策略,調(diào)用get時,如果異步執(zhí)行沒有結(jié)束,get會阻塞當(dāng)前調(diào)用線程,直到異步執(zhí)行結(jié)束并獲得結(jié)果,如果異步執(zhí)行已經(jīng)結(jié)束,不等待獲取執(zhí)行結(jié)果;如果選擇同步執(zhí)行策略,只有當(dāng)調(diào)用get函數(shù)時,同步調(diào)用才真正執(zhí)行,這也被稱為函數(shù)調(diào)用被延遲。
c、返回結(jié)果std::future的狀態(tài):
(1)、deffered:異步操作還沒有開始;
(2)、ready:異步操作已經(jīng)完成;
(3)、timeout:異步操作超時。
實(shí)例1(異步執(zhí)行和同步執(zhí)行):
// STLasync.cpp : 此文件包含 "main" 函數(shù)。程序執(zhí)行將在此處開始并結(jié)束。 // #include "pch.h" #include <iostream> #include <string> #include <chrono> #include <thread> #include <future> using namespace std::chrono; std::string fetchDataFromDB(std::string recvData) { std::cout << "fetchDataFromDB start" << std::this_thread::get_id() << std::endl; std::this_thread::sleep_for(seconds(5)); return "DB_" + recvData; } std::string fetchDataFromFile(std::string recvData) { std::cout << "fetchDataFromFile start" << std::this_thread::get_id() << std::endl; std::this_thread::sleep_for(seconds(3)); return "File_" + recvData; } int main() { std::cout << "main start" << std::this_thread::get_id() << std::endl; //獲取開始時間 system_clock::time_point start = system_clock::now(); std::future<std::string> resultFromDB = std::async(std::launch::async, fetchDataFromDB, "Data"); //從文件獲取數(shù)據(jù) std::future<std::string> fileData = std::async(std::launch::deferred, fetchDataFromFile, "Data"); //知道調(diào)用get函數(shù)fetchDataFromFile才開始執(zhí)行 std::string FileData = fileData.get(); //如果fetchDataFromDB()執(zhí)行沒有完成,get會一直阻塞當(dāng)前線程 std::string dbData = resultFromDB.get(); //獲取結(jié)束時間 auto end = system_clock::now(); auto diff = duration_cast<std::chrono::seconds>(end - start).count(); std::cout << "Total Time taken= " << diff << "Seconds" << std::endl; //組裝數(shù)據(jù) std::string data = dbData + " :: " + FileData; //輸出組裝的數(shù)據(jù) std::cout << "Data = " << data << std::endl; return 0; }
實(shí)例2(查詢future的狀態(tài)獲取異步執(zhí)行的結(jié)果):
// STLasync.cpp : 此文件包含 "main" 函數(shù)。程序執(zhí)行將在此處開始并結(jié)束。 // #include "pch.h" #include <iostream> #include <string> #include <chrono> #include <thread> #include <future> using namespace std::chrono; std::string fetchDataFromDB(std::string recvData) { std::cout << "fetchDataFromDB start" << std::this_thread::get_id() << std::endl; std::this_thread::sleep_for(seconds(5)); return "DB_" + recvData; } int main() { std::cout << "main start" << std::this_thread::get_id() << std::endl; //獲取開始時間 system_clock::time_point start = system_clock::now(); std::future<std::string> resultFromDB = std::async(std::launch::async, fetchDataFromDB, "Data"); std::future_status status; std::string dbData; do { status = resultFromDB.wait_for(std::chrono::seconds(1)); switch (status) { case std::future_status::ready: std::cout << "Ready..." << std::endl; //獲取結(jié)果 dbData = resultFromDB.get(); std::cout << dbData << std::endl; break; case std::future_status::timeout: std::cout << "timeout..." << std::endl; break; case std::future_status::deferred: std::cout << "deferred..." << std::endl; break; default: break; } } while (status != std::future_status::ready); //獲取結(jié)束時間 auto end = system_clock::now(); auto diff = duration_cast<std::chrono::seconds>(end - start).count(); std::cout << "Total Time taken= " << diff << "Seconds" << std::endl; return 0; }
輸出:
main start9096
fetchDataFromDB start7980
timeout...
timeout...
timeout...
timeout...
Ready...
DB_Data
Total Time taken= 5Seconds
參考:http://www.dbjr.com.cn/article/198765.htm
總結(jié)
到此這篇關(guān)于C++中std::async()的文章就介紹到這了,更多相關(guān)C++ std::async()詳解內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
C語言驅(qū)動開發(fā)之內(nèi)核使用IO/DPC定時器詳解
本章將繼續(xù)探索驅(qū)動開發(fā)中的基礎(chǔ)部分,定時器在內(nèi)核中同樣很常用,在內(nèi)核中定時器可以使用兩種,即IO定時器,以及DPC定時器,感興趣的可以了解一下2023-04-04Qt基礎(chǔ)開發(fā)之Qt多線程類QThread與Qt定時器類QTimer的詳細(xì)方法與實(shí)例
這篇文章主要介紹了Qt基礎(chǔ)開發(fā)之Qt多線程類QThread與Qt定時器類QTimer的詳細(xì)方法與實(shí)例,需要的朋友可以參考下2020-03-03C語言中實(shí)現(xiàn)“17進(jìn)制”轉(zhuǎn)“10進(jìn)制”實(shí)例代碼
這篇文章主要介紹了C語言中實(shí)現(xiàn)“17進(jìn)制”轉(zhuǎn)“10進(jìn)制”實(shí)例代碼的相關(guān)資料,需要的朋友可以參考下2017-05-05C語言實(shí)現(xiàn)繪制LoveBeat愛心曲線的示例代碼
這篇文章主要為大家詳細(xì)介紹了如何溧陽C語言實(shí)現(xiàn)繪制LoveBeat愛心曲線,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2023-03-03