本篇文章给大家分享的是有关如何在C++11中使用std::future,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。
创新互联建站网站设计,为客户量身定制各类网站建设业务,包括企业型、电子商务型、响应式网站开发、行业门户型等各类网站,实战经验丰富,成功案例众多。以客户利益为出发点,创新互联建站网站制作为客户规划、按需网站建设符合企业需求、带有营销价值的网络建站方案认真对待每一个客户,我们不用口头的语言来吹擂我们的优秀,上千余家的成功案例见证着我们的成长。C++11中的std::future是一个模板类。std::future提供了一种用于访问异步操作结果的机制。std::future所引用的共享状态不能与任何其它异步返回的对象共享(与std::shared_future相反)( std::future references shared state that is not shared with any other asynchronous return objects (as opposed to std::shared_future))。一个future是一个对象,它可以从某个提供者的对象或函数中检索值,如果在不同的线程中,则它可以正确地同步此访问(A future is an object that can retrieve a value from some provider object or function, properly synchronizing this access if in different threads)。
有效的future是与共享状态(shared state)关联的future对象,可以通过调用以下函数(provider)来构造future对象:std::async、std::promise::get_future、std::packaged_task::get_future。future对象仅在它们是有效时才有用。
模板类std::future成员函数包括:
1. 构造函数:(1).不带参数的默认构造函数,此对象没有共享状态,因此它是无效的,但是可以通过移动赋值的方式将一个有效的future值赋值给它;(2).禁用拷贝构造;(3).支持移动构造。
2. 析构函数:销毁future对象,它是异常安全的。
3. get函数:(1).当共享状态就绪时,返回存储在共享状态中的值(或抛出异常)。(2).如果共享状态尚未就绪(即提供者尚未设置其值或异常),则该函数将阻塞调用的线程直到就绪。(3).当共享状态就绪后,则该函数将取消阻塞并返回(或抛出)释放其共享状态,这使得future对象不再有效,因此对于每一个future共享状态,该函数最多应被调用一次。(4).std::future
4. operator=:(1).禁用拷贝赋值。(2).支持移动赋值:如果在调用之前,此对象是有效的(即它已经访问共享状态),则将其与先前已关联的共享状态解除关联。如果它是与先前共享状态关联的唯一对象,则先前的共享状态也会被销毁。
5. share函数:获取共享的future,返回一个std::shared_future对象,该对象获取future对象的共享状态。future对象将不再有效。
6. valid函数:检查共享状态的有效性,返回当前的future对象是否与共享状态关联。一旦调用了std::future::get()函数,再调用此函数将返回false。
7. wait函数:(1).等待共享状态就绪。(2).如果共享状态尚未就绪(即提供者尚未设置其值或异常),则该函数将阻塞调用的线程直到就绪。(3).当共享状态就绪后,则该函数将取消阻塞并void返回。
8. wait_for函数:(1).等待共享状态在指定的时间内(time span)准备就绪。(2). 如果共享状态尚未就绪(即提供者尚未设置其值或异常),则该函数将阻塞调用的线程直到就绪或已达到设置的时间。(3).此函数的返回值类型为枚举类future_status。此枚举类有三种label:ready:共享状态已就绪;timeout:在指定的时间内未就绪;deferred:共享状态包含了一个延迟函数(deferred function)。
9. wait_until函数:(1). 等待共享状态在指定的时间点(time point)准备就绪。(2). 如果共享状态尚未就绪(即提供者尚未设置其值或异常),则该函数将阻塞调用的线程直到就绪或已达到指定的时间点。(3).此函数的返回值类型为枚举类future_status。
详细用法见下面的测试代码,下面是从其他文章中copy的测试代码,部分作了调整,详细内容介绍可以参考对应的reference:
#include "future.hpp" #include#include #include #include #include namespace future_ { /////////////////////////////////////////////////////////// // reference: http://www.cplusplus.com/reference/future/future/ int test_future_1() { { // constructor/get/operator= auto get_value = []() { return 10; }; std::future foo; // default-constructed std::future bar = std::async(get_value); // move-constructed int x = bar.get(); std::cout << "value: " << x << '\n'; // 10 //int x2 = bar.get(); // crash, 对于每个future的共享状态,get函数最多仅被调用一次 //std::cout << "value: " << x2 << '\n'; std::future foo2(std::async(get_value)); std::cout << "value: " << foo2.get() << '\n'; // 10 } { // share std::future fut = std::async([]() { return 10; }); std::shared_future shfut = fut.share(); //std::cout << "value: " << fut.get() << '\n'; // crash, 执行完fut.share()后,fut对象将变得无效 std::cout << "fut valid: " << fut.valid() << '\n';// 0 // shared futures can be accessed multiple times: std::cout << "value: " << shfut.get() << '\n'; // 10 std::cout << "its double: " << shfut.get() * 2 << '\n'; // 20, 对于std::shared_future对象,get函数可以被多次访问 } { // valid std::future foo, bar; foo = std::async([]() { return 10; }); bar = std::move(foo); if (foo.valid()) std::cout << "foo's value: " << foo.get() << '\n'; else std::cout << "foo is not valid\n"; // foo is not valid if (bar.valid()) std::cout << "bar's value: " << bar.get() << '\n'; // 10 else std::cout << "bar is not valid\n"; } { // wait auto is_prime = [](int x) { for (int i = 2; i < x; ++i) if (x%i == 0) return false; return true; }; // call function asynchronously: std::future fut = std::async(is_prime, 194232491); std::cout << "checking...\n"; fut.wait(); std::cout << "\n194232491 "; if (fut.get()) // guaranteed to be ready (and not block) after wait returns std::cout << "is prime.\n"; else std::cout << "is not prime.\n"; } { // wait_for auto is_prime = [](int x) { for (int i = 2; i < x; ++i) if (x%i == 0) return false; return true; }; // call function asynchronously: std::future fut = std::async(is_prime, 700020007); // 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::future::wait_for函数 std::cout << '.'; bool x = fut.get(); // retrieve return value std::cout << "\n700020007 " << (x ? "is" : "is not") << " prime.\n"; } return 0; } /////////////////////////////////////////////////////////// // reference: https://en.cppreference.com/w/cpp/thread/future int test_future_2() { // future from a packaged_task std::packaged_task task([] { return 7; }); // wrap the function std::future f1 = task.get_future(); // get a future std::thread t(std::move(task)); // launch on a thread // future from an async() std::future f2 = std::async(std::launch::async, [] { return 8; }); #ifdef _MSC_VER // future from a promise std::promise p; std::future f3 = p.get_future(); std::thread([&p] { p.set_value_at_thread_exit(9); }).detach(); // gcc 4.9 don't support this function #endif std::cout << "Waiting..." << std::flush; f1.wait(); f2.wait(); #ifdef _MSC_VER f3.wait(); #endif std::cout << "Done!\nResults are: " << f1.get() << ' ' << f2.get() << ' ' #ifdef _MSC_VER << f3.get() #endif << '\n'; t.join(); return 0; } /////////////////////////////////////////////////////////// // reference: https://thispointer.com/c11-multithreading-part-8-stdfuture-stdpromise-and-returning-values-from-thread/ void initiazer(std::promise * promObj) { std::cout << "Inside Thread" << std::endl; promObj->set_value(35); } int test_future_3() { std::promise promiseObj; std::future futureObj = promiseObj.get_future(); std::thread th(initiazer, &promiseObj); std::cout << "value: " << futureObj.get() << std::endl; th.join(); // If std::promise object is destroyed before setting the value the calling get() function on associated std::future object will throw exception. // A part from this, if you want your thread to return multiple values at different point of time then // just pass multiple std::promise objects in thread and fetch multiple return values from thier associated multiple std::future objects. return 0; } } // namespace future_
以上就是如何在C++11中使用std::future,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注创新互联网站建设公司行业资讯频道。
另外有需要云服务器可以了解下创新互联建站www.cdcxhl.com,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。