本文主要是介绍56 C++多线程 将可调用对象打包 --- packaged_task 类模版,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
一 前提:
前面我们学习了怎么样使用thread 对象 启动一个线程。
然后学习了使用 async() 启动一个线程,然后通过async的返回值future获得返回值。
上面的两种,本质上都是从一个可调用对象开始执行的代码。------- 或者从 函数开始 执行。或者从 lambda表达式开始 执行。
二 这里我们学习一种 将这个 可调用对象 打包的类 packaged_task.好处是返回值可以通过future获得,那么如果这个可调用对象要做子线程的入口函数,那么就又可以获得子线程入口函数的返回值了。
2.1 定义
既然是打包一个 可调用对象 ,那么我们可以想象一下,可调用对象是要有 返回值,函数名,函数参数的。如下写法:
packaged_task<int, (string)> mypackaged_task(myfunc);
说明:
int 是 函数myfunc 的返回值。
string是函数myfunc 的参数类型。
myfunc 是函数,也就是可调用对象。
2.2使用
2.2.1 直接使用方法
2.2.2 使用类成员
TODO
2.2.3 结合线程使用
2.2.3使用vector 如何将 packaged-task存储起来,以便用的时候调用
class Teacher178 {
public:mutex mymutex;list<int> mylist;public:int readfunc(string &tempstr) {for (size_t i = 0; i < 10; i++){mymutex.lock();cout << "read func tempstr = " << tempstr << " i = " << i << " threadid = " << this_thread::get_id() << " &tempstr = " << &tempstr << " tempstr = " << tempstr << endl;mymutex.unlock();}return 10;}int writefunc(const int &tempdouble) {for (size_t i = 0; i < 10; i++){mymutex.lock();cout << "write func tempdouble = " << tempdouble << " i = " << i << " threadid = " << this_thread::get_id() << " &tempdouble = " << &tempdouble << " tempdouble = " << tempdouble << endl;mymutex.unlock();}return (int)tempdouble;}public:Teacher178() {cout << "Teacher178 构造方法被执行" << endl;}~Teacher178() {cout << "Teacher178 析构方法被执行" << endl;}Teacher178(const Teacher178& tea) {cout << "Teacher178 copy 构造 被执行" << endl;}
};
//int myfuncpackaged_taskconst( string & tempstr)
int myfuncpackaged_taskconst(const string & tempstr) {//如果不加const不能直接调用,需要使用bind函数将函数名和参数绑定cout << "myfuncpackaged_taskconst this_thread = " << this_thread::get_id() << " tempstr = " << tempstr << " & tempstr = " << &tempstr <<endl;return 999;
}int myfuncpackaged_task( string & tempstr) {cout << "myfuncpackaged_task this_thread = " << this_thread::get_id() << " tempstr = " << tempstr << " & tempstr = " << &tempstr << endl;return 888;
}
void main() {//1.正常调用string name = "nihao";int dou = 300;cout << "main threadid = " << this_thread::get_id() << " &name = " << &name << " name = " << name << " dou = " << dou << " &dou = " << &dou << endl;packaged_task<int(string)> mypackaged_task(myfuncpackaged_taskconst);mypackaged_task(name);cout << mypackaged_task.get_future().get() << endl;//packaged_task<int(string)> mypackaged_task6(myfuncpackaged_taskconst); //没有加const,不能这么调用,会有build error//mypackaged_task6(name);//cout << mypackaged_task6.get_future().get() << endl;cout << "============" << endl;string name1 = "www.baidu.com";packaged_task<int()> mypackaged_task2(bind(myfuncpackaged_task,ref(name)));//packaged_task<int()> mypackaged_task2(bind(myfuncpackaged_task, name));//std::packaged_task<int()> task(std::bind(f, 2, 11)); 上述两行代码参考C++11 文档。如果带ref,则实参name和形参tempname是同一个地址mypackaged_task2();//调用future<int> fu2 = mypackaged_task2.get_future();cout << "fu2.get()" << fu2.get()<<endl;cout << "endsss。。。。。。。" << endl;//2. 类的成员函数调用,不知道怎么调用才合理,参考了C++文档,网上也没有查到相关的资料,如果有哪位大神看到过,或者写过,请帮忙指教一下。Teacher178 tea;//int readfunc(string &tempstr)//packaged_task<int(string)> teapacked_task(move(tea),bind(&Teacher178::readfunc,ref(name))); build errorcout << "thread start " << endl;//3.结合线程使用packaged_task<int()> mypackaged_task8(bind(myfuncpackaged_task, ref(name)));thread mythread(ref(mypackaged_task8));mythread.join();future<int> fu3 = mypackaged_task8.get_future();fu3.get();cout << "thread end " << endl;//4. vector中存储 mypackaged_task类型packaged_task<int()> mypackaged_task11(bind(myfuncpackaged_task, ref(name)));packaged_task<int()> mypackaged_task22(bind(myfuncpackaged_taskconst, ref(name)));vector<packaged_task<int()>> vec;vec.push_back(move(mypackaged_task11));vec.push_back(move(mypackaged_task22));for (vector<packaged_task<int()>>::iterator it = vec.begin(); it != vec.end(); it++) {packaged_task<int()> mypackaged_tasktemp = move( *it);mypackaged_tasktemp();future<int> tempfu = mypackaged_tasktemp.get_future();cout << "tempfu.get() = " << tempfu.get() << endl;}
}
这篇关于56 C++多线程 将可调用对象打包 --- packaged_task 类模版的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!