日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

std::async()详解

發布時間:2023/12/15 编程问答 35 豆豆
生活随笔 收集整理的這篇文章主要介紹了 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()详解的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。