C++異步操作future和aysnc與function和bind
異步操作
C++11為異步操作提供了4個(gè)接口
- std::future : 異步指向某個(gè)任務(wù),然后通過future特性去獲取任務(wù)函數(shù)的返回結(jié)果。
- std::aysnc: 異步運(yùn)行某個(gè)任務(wù)函數(shù)。
- std::packaged_task :將任務(wù)和feature綁定在一起的模板,是一種封裝對(duì)任務(wù)的封裝。
- std::promise:承諾
std::future和std::aysnc 介紹
std::future期待一個(gè)函數(shù)的返回值,從一個(gè)異步調(diào)用的角度來說,future更像是執(zhí)行函數(shù)的返回值,C++標(biāo)準(zhǔn)庫(kù)使用std::future為一次性事件建模,如果一個(gè)事件需要等待特定的一次性事件,那么這線程可以獲取個(gè)future對(duì)象來代表這個(gè)事件。
異步調(diào)用往往不知道何時(shí)返回,但是如果異步調(diào)用的過程需要同步,或者說后一個(gè)異步調(diào)用需要使用前一個(gè)異步調(diào)用的結(jié)果。這個(gè)時(shí)候就要用到future。也就是說,可選擇同步,也可選擇異步。
future的表現(xiàn)為期望,當(dāng)前線程持有future時(shí),期望從future獲取到想要的結(jié)果和返回,可以把future當(dāng)做異步函數(shù)的返回值。
線程可以周期性的在這個(gè)future上等待一小段時(shí)間,檢查future是否已經(jīng)ready,如果沒有,該線程可以先去做另一個(gè)任務(wù),一旦future就緒,該future就無(wú)法復(fù)位(無(wú)法再次使用這個(gè)future等待這個(gè)事件),所以future代表的是一次性事件。
在庫(kù)的頭文件中聲明了兩種future,唯一future(std::future)和共享future(std::shared_future)這兩個(gè)是參照std::unique_ptr和std::shared_ptr設(shè)立的,前者的實(shí)例是僅有的一個(gè)指向其關(guān)聯(lián)事件的實(shí)例,而后者可以有多個(gè)實(shí)例指向同一個(gè)關(guān)聯(lián)事件,當(dāng)事件就緒時(shí),所有指向同一事件的std::shared_future實(shí)例會(huì)變成就緒。
跟thread類似,async允許你通過將額外的參數(shù)添加到調(diào)用中,來將附加參數(shù)傳遞給函數(shù)。如果傳入的函數(shù)指針是某個(gè)類的成員函數(shù),則還需要將類對(duì)象指針傳入(直接傳入,傳入指針,或者是std::ref封裝)。
默認(rèn)情況下,std::async是否啟動(dòng)一個(gè)新線程,或者在等待future時(shí),任務(wù)是否同步運(yùn)行都取決于你給的參數(shù)。這個(gè)參數(shù)為std::launch類型,async運(yùn)行某個(gè)任務(wù)函數(shù),至于異步運(yùn)行還是同步運(yùn)行,由這個(gè)參數(shù)決定
默認(rèn)選項(xiàng)參數(shù)被設(shè)置為std::launch::any。如果函數(shù)被延遲運(yùn)行可能永遠(yuǎn)都不會(huì)運(yùn)行,因?yàn)楹苡锌赡軐?duì)應(yīng)的future沒有調(diào)用get。
enum class launch{
async,deferred,sync=deferred,any=async|deferred
};- std::launch::async,表明函數(shù)會(huì)在創(chuàng)建的新線程上運(yùn)行。
- std::launch::defered表明該函數(shù)會(huì)被延遲調(diào)用,直到在future上調(diào)用get()或者wait()為止。
- std::launch::sync = std::launch::defered,表明該函數(shù)會(huì)被延遲調(diào)用
- std::launch::any = std::launch::defered | std::launch::async,表明該函數(shù)會(huì)被延遲調(diào)用,調(diào)用時(shí)在新線程上運(yùn)行。
std::future和std::aysnc的使用Demo
這里我們future了兩個(gè)函數(shù),第一個(gè)函數(shù)設(shè)置為異步,那么在第20行之后,就會(huì)創(chuàng)建一個(gè)新線程并運(yùn)行,而不必等待result.get()。第二個(gè)函數(shù)沒有設(shè)置參數(shù),那么默認(rèn)是延遲調(diào)用,只有在result2.get()時(shí),才會(huì)創(chuàng)建一個(gè)新線程并運(yùn)行。
#include <iostream>
#include <future>
#include <thread>
using namespace std;
int find_result_to_add() {
//std::this_thread::sleep_for(std::chrono::seconds(2)); // 用來測(cè)試異步延遲的影響
std::cout << "find_result_to_add" << std::endl;
return 1 + 1;
}
int find_result_to_add2(int a, int b) {
//std::this_thread::sleep_for(std::chrono::seconds(5)); // 用來測(cè)試異步延遲的影響
return a + b;
}
void do_other_things() {
std::cout << "do_other_things" << std::endl;
std::this_thread::sleep_for(std::chrono::seconds(5));
}
int main() {
//async異步
std::future<int> result = std::async(std::launch::async,find_result_to_add);
//std::future<decltype (find_result_to_add())> result = std::async(find_result_to_add);
//auto result = std::async(find_result_to_add); // 推薦的寫法用aoto
do_other_things();
std::cout << "result: " << result.get() << std::endl; // 延遲是否有影響?
//std::future<decltype (find_result_to_add2(0, 0))> result2 = std::async(find_result_to_add2, 10, 20);
//不寫默認(rèn)any
auto result2=std::async(find_result_to_add2, 10, 20);
std::cout << "result2: " << result2.get() << std::endl; // 延遲是否有影響?
std::cout << "main finish" << endl;
return 0;
}std::packaged_task 介紹
如果說std::async和std::feature還是分開看的關(guān)系的話,那么std::packaged_task就是將任務(wù)和feature綁定在一起的模板,是一種封裝對(duì)任務(wù)的封裝。
The class template std::packaged_task wraps any Callable target (function, lambda expression, bind expression, or another function object) so that it can be invoked asynchronously. Its return value or exception thrown is stored in a shared state which can be accessed through std::future objects.
可以通過std::packaged_task對(duì)象獲取任務(wù)相關(guān)聯(lián)的feature,調(diào)用get_future()方法可以獲得std::packaged_task對(duì)象綁定的函數(shù)的返回值類型的future。std::packaged_task的模板參數(shù)是函數(shù)簽名。( 例如int add(int a, intb)的函數(shù)簽名就是int(int, int) )
std::packaged_task的使用Demo
#include <iostream>
#include <future>
using namespace std;
int add(int a, int b, int c) {
std::cout << "call add\n";
return a + b + c;
}
void do_other_things() {
std::cout << "do_other_things" << std::endl;
}
int main() {
std::packaged_task<int(int, int, int)> task(add); // 封裝任務(wù)
do_other_things();
std::future<int> result = task.get_future();
task(1, 1, 2); //必須要讓任務(wù)執(zhí)行,否則在get()獲取future的值時(shí)會(huì)一直阻塞
std::cout << "result:" << result.get() << std::endl;
return 0;
}std::promise 的介紹
std::promise提供了一種設(shè)置值的方式,它可以在這之后通過相關(guān)聯(lián)的std::future對(duì)象進(jìn)行讀取。換種說法,之前已經(jīng)說過std::future可以讀取一個(gè)異步函數(shù)的返回值了,那么這個(gè)std::promise就提供一種方式手動(dòng)讓future就緒
出在promise創(chuàng)建好的時(shí)候future也已經(jīng)創(chuàng)建好了,線程在創(chuàng)建promise的同時(shí)會(huì)獲得一個(gè)future,然后將promise傳遞給設(shè)置他的線程,當(dāng)前線程則持有future,以便隨時(shí)檢查是否可以取值。
promise是一個(gè)承諾,當(dāng)線程創(chuàng)建了promise對(duì)象后,這個(gè)promise對(duì)象向線程承諾他必定會(huì)被人設(shè)置一個(gè)值,和promise相關(guān)聯(lián)的future就是獲取其返回的手段。
std::promise的使用Demo
#include <future>
#include <string>
#include <thread>
#include <iostream>
using namespace std;
void print(std::promise<std::string>& p) {
p.set_value("There is the result whitch you want.");
}
void do_some_other_things() {
std::cout << "Hello World" << std::endl;
}
int main() {
std::promise<std::string> promise;
std::future<std::string> result = promise.get_future();
std::thread th(print, std::ref(promise));
do_some_other_things();
std::cout << result.get() << std::endl;
th.join();
return 0;
}function和bind
在設(shè)計(jì)回調(diào)函數(shù)的時(shí)候,無(wú)可避免地會(huì)接觸到可回調(diào)對(duì)象。在C++11中,提供了std::function和std::bind兩個(gè)方法來對(duì)可回調(diào)對(duì)象進(jìn)行統(tǒng)一和封裝。(回調(diào)函數(shù)就是一個(gè)被作為參數(shù)傳遞的函數(shù))
C++語(yǔ)言中有幾種可調(diào)用對(duì)象:函數(shù)、函數(shù)指針、lambda表達(dá)式、bind創(chuàng)建的對(duì)象以及重載了函數(shù)調(diào)用運(yùn)算符的類。和其他對(duì)象一樣,可調(diào)用對(duì)象也有類型。例如,每個(gè)lambda有它自己唯一的(未命名)類類型;函數(shù)及函數(shù)指針的類型則由其返回值類型和實(shí)參類型決定。
function的用法
頭文件:#include <functional>
- 保存普通函數(shù)
//保存普通函數(shù)
void func1(int a) {
cout << a << endl;
}
//1. 保存普通函數(shù)
std::function<void(int a)> func1_;
func1_ = func1;
func1_(2); //2- 保存lambda表達(dá)式
//2. 保存lambda表達(dá)式
std::function<void()> func2_ = []() {
cout << "hello lambda" << endl;
};
func2_(); //hello world- 保存成員函數(shù)
//保存成員函數(shù)
class A {
public:
A(string name) : name_(name) {}
void func3(int i) const {
cout <<name_ << ", " << i << endl;
}
private:
string name_;
};
//3 保存成員函數(shù)
std::function<void(const A&,int)> func3_ = &A::func3;
A a("wxf");
func3_(a, 20);完整代碼:
#include <iostream>
#include <functional>
using namespace std;
//保存普通函數(shù)
void func1(int a) {
cout << a << endl;
}
//保存成員函數(shù)
class A {
public:
A(string name) : name_(name) {}
void func3(int i) const {
cout <<name_ << ", " << i << endl;
}
private:
string name_;
};
int main() {
cout << "main1 -----------------" << endl;
//1. 保存普通函數(shù)
std::function<void(int a)> func1_;
func1_ = func1;
func1_(2); //2
cout << "\n\nmain2 -----------------" << endl;
//2. 保存lambda表達(dá)式
std::function<void()> func2_ = []() {
cout << "hello lambda" << endl;
};
func2_(); //hello world
cout << "\n\nmain3 -----------------" << endl;
//3 保存成員函數(shù)
std::function<void(const A&,int)> func3_ = &A::func3;
A a("wxf");
func3_(a, 20);
return 0;
}main1 ----------------- 2 main2 ----------------- hello lambda main3 ----------------- wxf, 20
bind的用法
可將bind函數(shù)看作是一個(gè)通用的函數(shù)適配器,它接受一個(gè)可調(diào)用對(duì)象,生成一個(gè)新的可調(diào)用對(duì)象來“適應(yīng)”原對(duì)象的參數(shù)列表。調(diào)用bind的一般形式:auto newCallable = bind(callable, arg_list);
其中,newCallable本身是一個(gè)可調(diào)用對(duì)象,arg_list是一個(gè)逗號(hào)分隔的參數(shù)列表,對(duì)應(yīng)給定的callable的參數(shù)。即,當(dāng)我們調(diào)用newCallable時(shí),newCallable會(huì)調(diào)用callable,并傳給它arg_list中的參數(shù)。
arg_list中的參數(shù)可能包含形如placeholders::_n的名字,其中n是一個(gè)整數(shù),這些參數(shù)是“占位符”,表示newCallable的參數(shù),它們占據(jù)了傳遞給newCallable的參數(shù)的“位置”。數(shù)值n表示生成的可調(diào)用對(duì)象中參數(shù)的位置:placeholders::_1為newCallable的第一個(gè)參數(shù),placeholders::_2為第二個(gè)參數(shù),以此類推。
可能看描述還不是很懂,下面來看看代碼:
#include <iostream>
#include <functional>
using namespace std;
void fun_1(int x,int y,int z) {
cout<<"fun_1 print unchanged: x=" <<x<<",y="<< y << ",z=" <<z<<endl;
}
void fun_2(int &a,int &b) {
a++;
b++;
cout<<"fun_2 print Increment: a=" <<a<<",b="<<b<<endl;
}
class A {
public:
// 重載fun_3,主要bind的時(shí)候需要
// std::bind((void(A::*)(int, int))&A::fun_3
void fun_3(int k,int m) {
cout << "fun_3 a = " << a << cout <<"\t print unchanged: k="<<k<<",m="<<m<<endl;
}
// std::bind((void(A::*)(string))&A::fun_3
void fun_3(string str) {
cout<<"fun_3 print: str="<<str<<endl;
}
int a;
};
int main() {
//f1的類型為 function<void(int, int, int)>
cout << "\n\nstd::bind(fun_1, 1, 2, 3) -----------------\n";
auto f1 = std::bind(fun_1, 1, 2, 3); //表示綁定函數(shù) fun 的第一,二,三個(gè)參數(shù)值為:1 2 3
f1(); //print: x=1,y=2,z=3
cout << "\n\nstd::bind(fun_1, 10, 20, 30) -----------------\n";
auto f1_1 = std::bind(fun_1, 10, 20, 30); //表示綁定函數(shù) fun 的第一,二,三個(gè)參數(shù)值為: 1 2 3
f1_1();
cout << "\n\nstd::bind(fun_1, placeholders::_1,placeholders::_2, 3) -----------------\n";
auto f2 = std::bind(fun_1, placeholders::_1, placeholders::_2, 3);
//表示綁定函數(shù) fun_1的第三個(gè)參數(shù)為 3,而fun_1的第一,二個(gè)參數(shù)分別由調(diào)用 f2 的第一,二個(gè)參數(shù)指定
f2(1,2);//print: x=1,y=2,z=3
f2(10,21,30); // 傳入30也沒有用
cout << "\n\nstd::bind(fun_1,placeholders::_2,placeholders::_1,3) -----------------\n";
auto f3 = std::bind(fun_1,placeholders::_2,placeholders::_1,3);
//表示綁定函數(shù) fun_1 的第三個(gè)參數(shù)為 3,而fun_1的第一,二個(gè)參數(shù)分別由調(diào)用 f3 的第二,一個(gè)參數(shù)指定
//注意: f2 和 f3 的區(qū)別。
f3(1,2);//print: x=2,y=1,z=3
cout << "\n\nstd::bind(fun_2, placeholders::_1, n) -----------------\n";
int m = 2;
int n = 3;
////表示綁定fun_2的第一個(gè)參數(shù)為n, fun_2的第二個(gè)參數(shù)由調(diào)用f4的第一個(gè)參數(shù)(_1)指定。
auto f4 = std::bind(fun_2, placeholders::_1, n); //func_2(3,<f4_1>)
f4(m); //print: m=3,n=4
cout<<"m="<<m<<endl;//m=3 說明:bind對(duì)于不事先綁定的參數(shù),通過std::placeholders傳遞的參數(shù)是通過引用傳遞的,如m
cout<<"n="<<n<<endl;//n=3 說明:bind對(duì)于預(yù)先綁定的函數(shù)參數(shù)是通過值傳遞的,如n
cout << "\n\nstd::bind(&A::fun_3,&a1,40,50) -----------------\n";
A a;
a.a = 10;
//f5的類型為 function<void(int, int)>
auto f5 = std::bind((void(A::*)(int, int))A::fun_3, &a, 40, 50);
f5(10,20);//參數(shù)以及寫死,傳參沒用
cout << "\n\nstd::bind(&A::fun_3, &a2,placeholders::_1,placeholders::_2) -----------------\n";
A a2;
a2.a = 20;
//f5的類型為 function<void(int, int)>
auto f6 = std::bind((void(A::*)(int, int))&A::fun_3,&a2,placeholders::_1,placeholders::_2); //使用auto關(guān)鍵字
f6(10,20);//調(diào)用a.fun_3(10,20),print: k=10,m=20
cout << "\n\nstd::bind(&A::fun_3,a3,std::placeholders::_1,std::placeholders::_2) -----------------\n";
std::function<void(int,int)> fc = std::bind((void(A::*)(int,int))&A::fun_3, &a,std::placeholders::_1,std::placeholders::_2);
fc(10,20); //調(diào)用a.fun_3(10,20) print: k=10,m=20
fc = std::bind((void(A::*)(int, int))&A::fun_3,&a2,std::placeholders::_1,std::placeholders::_2);
cout << "\n\nstd::bind(&A::fun_3,&a1,std::placeholders::_1) -----------------\n";
auto f_str = std::bind((void(A::*)(string))&A::fun_3,a,std::placeholders::_1);
f_str("wxf");
return 0;
}

到此這篇關(guān)于C++異步操作future和aysnc與function和bind的文章就介紹到這了,更多相關(guān)C++異步操作內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
C++ boost::asio編程-同步TCP詳解及實(shí)例代碼
這篇文章主要介紹了C++ boost::asio編程-同步TCP詳解及實(shí)例代碼的相關(guān)資料,需要的朋友可以參考下2016-11-11
C++實(shí)現(xiàn)簡(jiǎn)單職工信息管理系統(tǒng)
本文給大家分享的是使用C++實(shí)現(xiàn)簡(jiǎn)單的職工信息管理系統(tǒng)的代碼,本系統(tǒng)采用了面向?qū)ο蟮某绦蛟O(shè)計(jì)方法,所有的方法均以類為基礎(chǔ),感興趣的小伙伴們可以參考一下2015-08-08
C++簡(jiǎn)單又輕松的講解類和對(duì)象中友元函數(shù)
采用類的機(jī)制后實(shí)現(xiàn)了數(shù)據(jù)的隱藏與封裝,類的數(shù)據(jù)成員一般定義為私有成員,成員函數(shù)一般定義為公有的,依此提供類與外界間的通信接口。但是,有時(shí)需要定義一些函數(shù),這些函數(shù)不是類的一部分,但又需要頻繁地訪問類的數(shù)據(jù)成員,這時(shí)可以將這些函數(shù)定義為該類的友元函數(shù)2022-06-06
C語(yǔ)言詳細(xì)講解strcpy strcat strcmp函數(shù)的模擬實(shí)現(xiàn)
這篇文章主要介紹了怎樣用C語(yǔ)言模擬實(shí)現(xiàn)strcpy與strcat和strcmp函數(shù),strcpy()函數(shù)是C語(yǔ)言中的一個(gè)復(fù)制字符串的庫(kù)函數(shù),strcat()函數(shù)的功能是實(shí)現(xiàn)字符串的拼接,strcmp()函數(shù)作用是比較字符串str1和str2是否相同2022-05-05

