怎么在C++11中使用std::async方法-創(chuàng)新互聯(lián)

本篇文章給大家分享的是有關(guān)怎么在C++11中使用std::async方法，小編覺得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說(shuō)，跟著小編一起來(lái)看看吧。

創(chuàng)新互聯(lián)主要從事網(wǎng)站建設(shè)、做網(wǎng)站、網(wǎng)頁(yè)設(shè)計(jì)、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)谷城,10余年網(wǎng)站建設(shè)經(jīng)驗(yàn),價(jià)格優(yōu)惠、服務(wù)專業(yè),歡迎來(lái)電咨詢建站服務(wù):13518219792

std::async有兩個(gè)版本：

1.無(wú)需顯示指定啟動(dòng)策略，自動(dòng)選擇，因此啟動(dòng)策略是不確定的，可能是std::launch::async，也可能是std::launch::deferred，或者是兩者的任意組合，取決于它們的系統(tǒng)和特定庫(kù)實(shí)現(xiàn)。

2.允許調(diào)用者選擇特定的啟動(dòng)策略。

std::async的啟動(dòng)策略類型是個(gè)枚舉類enum class launch，包括：

1. std::launch::async：異步，啟動(dòng)一個(gè)新的線程調(diào)用Fn，該函數(shù)由新線程異步調(diào)用，并且將其返回值與共享狀態(tài)的訪問點(diǎn)同步。

2. std::launch::deferred：延遲，在訪問共享狀態(tài)時(shí)該函數(shù)才被調(diào)用。對(duì)Fn的調(diào)用將推遲到返回的std::future的共享狀態(tài)被訪問時(shí)(使用std::future的wait或get函數(shù))。

參數(shù)Fn：可以為函數(shù)指針、成員指針、任何類型的可移動(dòng)構(gòu)造的函數(shù)對(duì)象(即類定義了operator()的對(duì)象)。Fn的返回值或異常存儲(chǔ)在共享狀態(tài)中以供異步的std::future對(duì)象檢索。

參數(shù)Args：傳遞給Fn調(diào)用的參數(shù)，它們的類型應(yīng)是可移動(dòng)構(gòu)造的。

返回值：當(dāng)Fn執(zhí)行結(jié)束時(shí)，共享狀態(tài)的std::future對(duì)象準(zhǔn)備就緒。std::future的成員函數(shù)get檢索的值是Fn返回的值。當(dāng)啟動(dòng)策略采用std::launch::async時(shí)，即使從不訪問其共享狀態(tài)，返回的std::future也會(huì)鏈接到被創(chuàng)建線程的末尾。在這種情況下，std::future的析構(gòu)函數(shù)與Fn的返回同步。

std::future介紹參考：https://www.jb51.net/article/179229.htm

詳細(xì)用法見下面的測(cè)試代碼，下面是從其他文章中copy的測(cè)試代碼，部分作了調(diào)整，詳細(xì)內(nèi)容介紹可以參考對(duì)應(yīng)的reference：

#include "future.hpp"
#include <iostream>
#include <future>
#include <chrono>
#include <utility>
#include <thread>
#include <functional>
#include <memory>
#include <exception> 
#include <numeric>
#include <vector>
#include <cmath>
#include <string>
#include <mutex>
 
namespace future_ {
 
///////////////////////////////////////////////////////////
// reference: http://www.cplusplus.com/reference/future/async/
int test_async_1()
{
 auto is_prime = [](int x) {
 std::cout << "Calculating. Please, wait...\n";
 for (int i = 2; i < x; ++i) if (x%i == 0) return false;
 return true;
 };
 
 // call is_prime(313222313) asynchronously:
 std::future<bool> fut = std::async(is_prime, 313222313);
 
 std::cout << "Checking whether 313222313 is prime.\n";
 // ...
 
 bool ret = fut.get(); // waits for is_prime to return
 if (ret) std::cout << "It is prime!\n";
 else std::cout << "It is not prime.\n";
 
 return 0;
}
 
///////////////////////////////////////////////////////////
// reference: http://www.cplusplus.com/reference/future/launch/
int test_async_2()
{
 auto print_ten = [](char c, int ms) {
 for (int i = 0; i < 10; ++i) {
  std::this_thread::sleep_for(std::chrono::milliseconds(ms));
  std::cout << c;
 }
 };
 
 std::cout << "with launch::async:\n";
 std::future<void> foo = std::async(std::launch::async, print_ten, '*', 100);
 std::future<void> bar = std::async(std::launch::async, print_ten, '@', 200);
 // async "get" (wait for foo and bar to be ready):
 foo.get(); // 注：注釋掉此句，也會(huì)輸出'*'
 bar.get();
 std::cout << "\n\n";
 
 std::cout << "with launch::deferred:\n";
 foo = std::async(std::launch::deferred, print_ten, '*', 100);
 bar = std::async(std::launch::deferred, print_ten, '@', 200);
 // deferred "get" (perform the actual calls):
 foo.get(); // 注：注釋掉此句，則不會(huì)輸出'**********'
 bar.get();
 std::cout << '\n';
 
 return 0;
}
 
///////////////////////////////////////////////////////////
// reference: https://en.cppreference.com/w/cpp/thread/async
std::mutex m;
 
struct X {
 void foo(int i, const std::string& str) {
 std::lock_guard<std::mutex> lk(m);
 std::cout << str << ' ' << i << '\n';
 }
 void bar(const std::string& str) {
 std::lock_guard<std::mutex> lk(m);
 std::cout << str << '\n';
 }
 int operator()(int i) {
 std::lock_guard<std::mutex> lk(m);
 std::cout << i << '\n';
 return i + 10;
 }
};
 
template <typename RandomIt>
int parallel_sum(RandomIt beg, RandomIt end)
{
 auto len = end - beg;
 if (len < 1000)
 return std::accumulate(beg, end, 0);
 
 RandomIt mid = beg + len / 2;
 auto handle = std::async(std::launch::async, parallel_sum<RandomIt>, mid, end);
 int sum = parallel_sum(beg, mid);
 return sum + handle.get();
}
 
int test_async_3()
{
 std::vector<int> v(10000, 1);
 std::cout << "The sum is " << parallel_sum(v.begin(), v.end()) << '\n';
 
 X x;
 // Calls (&x)->foo(42, "Hello") with default policy:
 // may print "Hello 42" concurrently or defer execution
 auto a1 = std::async(&X::foo, &x, 42, "Hello");
 // Calls x.bar("world!") with deferred policy
 // prints "world!" when a2.get() or a2.wait() is called
 auto a2 = std::async(std::launch::deferred, &X::bar, x, "world!");
 // Calls X()(43); with async policy
 // prints "43" concurrently
 auto a3 = std::async(std::launch::async, X(), 43);
 a2.wait();           // prints "world!"
 std::cout << a3.get() << '\n'; // prints "53"
 
 return 0;
} // if a1 is not done at this point, destructor of a1 prints "Hello 42" here
 
///////////////////////////////////////////////////////////
// reference: https://thispointer.com/c11-multithreading-part-9-stdasync-tutorial-example/
int test_async_4()
{
 using namespace std::chrono;
 
 auto fetchDataFromDB = [](std::string recvdData) {
 // Make sure that function takes 5 seconds to complete
 std::this_thread::sleep_for(seconds(5));
 //Do stuff like creating DB Connection and fetching Data
 return "DB_" + recvdData;
 };
 
 auto fetchDataFromFile = [](std::string recvdData) {
 // Make sure that function takes 5 seconds to complete
 std::this_thread::sleep_for(seconds(5));
 //Do stuff like fetching Data File
 return "File_" + recvdData;
 };
 
 // Get Start Time
 system_clock::time_point start = system_clock::now();
 
 std::future<std::string> resultFromDB = std::async(std::launch::async, fetchDataFromDB, "Data");
 
 //Fetch Data from File
 std::string fileData = fetchDataFromFile("Data");
 
 //Fetch Data from DB
 // Will block till data is available in future<std::string> object.
 std::string dbData = resultFromDB.get();
 
 // Get End Time
 auto end = system_clock::now();
 auto diff = duration_cast <std::chrono::seconds> (end - start).count();
 std::cout << "Total Time Taken = " << diff << " Seconds" << std::endl;
 
 //Combine The Data
 std::string data = dbData + " :: " + fileData;
 //Printing the combined Data
 std::cout << "Data = " << data << std::endl;
 
 return 0;
}
 
} // namespace future_

以上就是怎么在C++11中使用std::async方法，小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘９ぷ鲿?huì)見到或用到的。希望你能通過這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站建設(shè)公司行業(yè)資訊頻道。

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)建站muchs.cn，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

文章名稱：怎么在C++11中使用std::async方法-創(chuàng)新互聯(lián)
轉(zhuǎn)載來(lái)于：http://muchs.cn/article28/poscp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)頁(yè)設(shè)計(jì)公司、域名注冊(cè)、響應(yīng)式網(wǎng)站、關(guān)鍵詞優(yōu)化、靜態(tài)網(wǎng)站、搜索引擎優(yōu)化

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)

營(yíng)銷型網(wǎng)站建設(shè)