当前位置：首页 > news >正文

56 C++多线程将可调用对象打包 --- packaged_task 类模版

news 来源：原创 2024/5/20 20:14:37

一前提：

前面我们学习了怎么样使用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;}
}