future和promise的作用是在不同线程之间传递数据。使用指针也可以完成数据的传递,但是指针非常危险,因为互斥量不能阻止指针的访问;而且指针的方式传递的数据是固定的,如果更改数据类型,那么还需要更改有关的接口,比较麻烦;promise支持泛型的操作,更加方便编程处理。
假设线程1需要线程2的数据,那么组合使用方式如下:
线程1初始化一个promise对象和一个future对象,promise传递给线程2,相当于线程2对线程1的一个承诺;future相当于一个接受一个承诺,用来获取未来线程2传递的值
线程2获取到promise后,需要对这个promise传递有关的数据,之后线程1的future就可以获取数据了。
如果线程1想要获取数据,而线程2未给出数据,则线程1阻塞,直到线程2的数据到达
/** @file 20190815future.cpp
* @note
* @brief
* @author
* @date 2019-8-15
* @note
* @history
* @warning*/#include #include #include #include #include #include voidthread_set_promise(std::promise& promiseObj) {
std::cout <<"In a thread, making data...";
std::this_thread::sleep_for(std::chrono::milliseconds(1000));
promiseObj.set_value(35);
std::cout <<"Finished";
}int main() {
std::promise promiseObj;
std::future futureObj = promiseObj.get_future();
std::thread t(&thread_set_promise, std::ref(promiseObj));
std::cout << futureObj.get() << std::endl;
t.join();
system("pause");
return0;
}
async(高级封装future和thread)
/** @file futureIsPrime.cpp
* @note
* @brief
* @author
* @date 2019-8-15
* @note
* @history
* @warning*/// future example#include // std::cout#include // std::async, std::future#include // std::chrono::milliseconds// a non-optimized way of checking for prime numbers:boolis_prime (int x) {
for(inti=2; i
returntrue;
}int main ()
{
// call function asynchronously:std::future fut = std::async (is_prime,444444443);
// do something while waiting for function to set future:std::cout <<"checking, please wait";
std::chrono::milliseconds span (100);
while(fut.wait_for(span)==std::future_status::timeout)
std::cout <<'.'<< std::flush;
boolx = fut.get();// retrieve return value std::cout <<"444444443 "<< (x?"is":"is not") <<" prime.";
return0;
}