future

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;
}

  

原文地址:https://www.cnblogs.com/ACGame/p/9108742.html