标签:拷贝 out pack 函数参数 获取 include lse 模板类 operator
thread库使用future范式提供了一种异步操作线程返回值的方法,因为这个返回值在现场开始执行时还是不可用的,是一个未来的期待值,所以被称为future。
future使用packaged_task和promise两个模板类来包装异步调用,用unique_future和shared_future来获取异步调用结果(即future值)。
packaged_task好像是一个reference_wrapper或者function对象,它提供operator(),包装了一个可回调物,然后它就可以被任意的线程调用执行,最后的future值可以用成员函数get_future()获得。
unique_future用来存储packaged_task异步计算得到的future值,它只能持有结果的唯一的一个应用。成员函数wait()可以阻塞等待packaged_task的执行,直至获得future值。成员函数is_ready()、has_value()和has_exception()分别用来测试unique_future是否可用,是否有值和是否发生了异常,如果一切正常那么可以使用get()获得future值。
#include <boost/thread.hpp> #include <boost/ref.hpp> #include <iostream> int fab(int n) { if (n == 0 || n == 1) return 1; else return fab(n - 1) + fab(n - 2); } int main() { // 声明packaged_task对象,用模板参数指明返回值类型 // packaged_task只接受无参函数,因此需要使用bind boost::packaged_task<int> pt(boost::bind(fab, 10)); // 声明unique_future对象,接受packaged_task的future值, // 用模板参数指明返回值类型 boost::unique_future<int> uf = pt.get_future(); // 启动线程计算, 必须使用boost::move()来转移packaged_task对象, // 因为packaged_task是不可拷贝的 boost::thread(boost::move(pt)); uf.wait(); assert(uf.is_ready() && uf.has_value()); // 等待计算结果 std::cout << uf.get() << std::endl; return 0; }
promise也用于处理异步调用返回值,但它不同于packaged_task,不能包装一个函数,而是包装一个值,这个值可以作为函数的输出参数,适用于从函数参数获取返回值的函数。
promise的用法与packaged_task类似,在线程中用set_value()设置要返回的值,用成员函数get_future()获得future值赋给future对象。
#include <boost/thread.hpp> #include <boost/ref.hpp> #include <iostream> int fab(int n) { if (n == 0 || n == 1) return 1; else return fab(n - 1) + fab(n - 2); } void fab2(int n, boost::promise<int> *p) // 使用promise作为输出参数 { p->set_value(fab(n)); } int main() { boost::promise<int> p; boost::unique_future<int> uf = p.get_future(); // 赋值future对象 boost::thread(fab2, 10, &p); // 启动线程 uf.wait(); // 等待计算结果 std::cout << uf.get() << std::endl; return 0; }
标签:拷贝 out pack 函数参数 获取 include lse 模板类 operator
原文地址:https://www.cnblogs.com/ACGame/p/9108742.html