std::async()详解
1、std::async函數原型:
template<class Fn, class... Args> future<typename result_of<Fn(Args...)>::type> async(launch policy, Fn&& fn, Args&&...args);功能:第二個參數接收一個可調用對象(仿函數、lambda表達式、類成員函數、普通函數......)作為參數,并且異步或是同步執行他們。
a、對于是異步執行還是同步執行,由第一個參數的執行策略決定:
(1)、std::launch::async 傳遞的可調用對象異步執行;
(2)、std::launch::deferred 傳遞的可調用對象同步執行;
(3)、std::launch::async | std::launch::deferred 可以異步或是同步,取決于操作系統,我們無法控制;
(4)、如果我們不指定策略,則相當于(3)。
?b、對于執行結果:
我們可以使用get、wait、wait_for、wait_until等待執行結束,區別是get可以獲得執行的結果。如果選擇異步執行策略,調用get時,如果異步執行沒有結束,get會阻塞當前調用線程,直到異步執行結束并獲得結果,如果異步執行已經結束,不等待獲取執行結果;如果選擇同步執行策略,只有當調用get函數時,同步調用才真正執行,這也被稱為函數調用被延遲。
c、返回結果std::future的狀態:
(1)、deffered:異步操作還沒有開始;
(2)、ready:異步操作已經完成;
(3)、timeout:異步操作超時。
實例1(異步執行和同步執行):
// STLasync.cpp : 此文件包含 "main" 函數。程序執行將在此處開始并結束。 //#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");//從文件獲取數據std::future<std::string> fileData = std::async(std::launch::deferred, fetchDataFromFile, "Data");//直到調用get函數fetchDataFromFile才開始執行std::string FileData = fileData.get();//如果fetchDataFromDB()執行沒有完成,get會一直阻塞當前線程std::string dbData = resultFromDB.get();//獲取結束時間auto end = system_clock::now();auto diff = duration_cast<std::chrono::seconds>(end - start).count();std::cout << "Total Time taken= " << diff << "Seconds" << std::endl;//組裝數據std::string data = dbData + " :: " + FileData;//輸出組裝的數據std::cout << "Data = " << data << std::endl;return 0; }實例2(查詢future的狀態獲取異步執行的結果):
// STLasync.cpp : 此文件包含 "main" 函數。程序執行將在此處開始并結束。 //#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;//獲取結果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);//獲取結束時間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
總結
以上是生活随笔為你收集整理的std::async()详解的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 罗马尼亚总理启用全球首个人工智能顾问 民
- 下一篇: std::bind绑定成员函数,为什么第