C++ packaged_task
packaged_task
是 C++11 标准库中引入的一个模板类,它用于将可调用对象(如函数、lambda 表达式、函数对象或绑定表达式)包装起来,并允许异步地获取其结果packaged_task
类提供了一种方便的方式来创建任务,这些任务可以被放入线程中执行,而任务的结果可以在需要时通过 future
对象来获取。
-
定义任务:首先,你需要定义一个可调用对象,这个对象就是你想要异步执行的任务。
-
包装任务:使用
packaged_task
模板类将你的可调用对象包装起来。在包装时,你需要指定返回类型和参数类型,这些类型应该与你的可调用对象相匹配。 -
获取 future 对象:通过调用
packaged_task
对象的get_future()
方法,你可以获取一个future
对象。这个future
对象将用于在稍后获取任务的结果。 -
执行任务:将
packaged_task
对象传递给一个线程,使其在新线程中执行。 -
获取结果:在需要的时候,通过之前获取的
future
对象调用get()
方法来获取任务的结果。注意,如果任务尚未完成,get()
方法会阻塞,直到任务完成并返回结果。 -
注意:被
packaged_task
包装的对象,它可以当作一个可调用对象来调用任务执行,但它又不能完全的当作一个函数来使用,他不能想普通函数一样传递给线程使用。我们可以将它封装成为一个指针,传递给线程,然后解引用执行。但如果单纯指向以恶搞对象,存在生命周期的问题。所以我们可以在堆上new对象,用智能指针去管理它的生命周期。
下面是一段示例:
#include<iostream>
#include<future>
#include<thread>
#include<memory>
#include<string>
#include <chrono>int add(int x, int y)
{std::this_thread::sleep_for(std::chrono::seconds(3));return x + y;
}int main()
{auto ptask = std::make_shared < std::packaged_task<int(int, int)>>(add);std::future<int> fu = ptask->get_future();std::thread thr([ptask]() {(*ptask)(1, 2);});int num = fu.get();std::cout << num;thr.join();return 0;
}