| // Copyright (C) 2012 Vicente Botet |
| // |
| // Distributed under the Boost Software License, Version 1.0. (See accompanying |
| // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) |
| |
| #include <boost/config.hpp> |
| #if ! defined BOOST_NO_CXX11_DECLTYPE |
| #define BOOST_RESULT_OF_USE_DECLTYPE |
| #endif |
| |
| #define BOOST_THREAD_VERSION 4 |
| |
| #include <boost/thread/future.hpp> |
| #include <iostream> |
| |
| namespace boost |
| { |
| |
| template <typename T> |
| exception_ptr make_exception_ptr(T v) |
| { |
| return copy_exception(v); |
| } |
| } |
| |
| int p1() { return 5; } |
| int& p1r() { static int i=0; return i; } |
| |
| void p() { } |
| |
| #if defined BOOST_THREAD_USES_MOVE |
| boost::future<void> void_compute() |
| { |
| return BOOST_THREAD_MAKE_RV_REF(boost::make_ready_future()); |
| } |
| #endif |
| |
| boost::future<int> compute(int x) |
| { |
| if (x == 0) return boost::make_ready_future(0); |
| #ifdef BOOST_NO_CXX11_RVALUE_REFERENCES |
| if (x < 0) return boost::make_exceptional_future<int>(std::logic_error("Error")); |
| #else |
| if (x < 0) return boost::make_exceptional(std::logic_error("Error")); |
| #endif |
| //boost::future<int> f1 = boost::async([]() { return x+1; }); |
| boost::future<int> f1 = boost::async(p1); |
| return boost::move(f1); |
| } |
| |
| boost::future<int&> compute_ref(int x) |
| { |
| static int i = 0; |
| //if (x == 0) return boost::make_ready_future<int&>(i); //This must not compile as the type is deduced as boost::future<int> |
| if (x == 0) return boost::make_ready_no_decay_future<int&>(i); |
| #ifdef BOOST_NO_CXX11_RVALUE_REFERENCES |
| if (x < 0) return boost::make_exceptional_future<int&>(std::logic_error("Error")); |
| #else |
| if (x < 0) return boost::make_exceptional(std::logic_error("Error")); |
| #endif |
| boost::future<int&> f1 = boost::async(p1r); |
| return boost::move(f1); |
| } |
| |
| boost::shared_future<int> shared_compute(int x) |
| { |
| if (x == 0) return boost::make_ready_future(0).share(); |
| #ifdef BOOST_NO_CXX11_RVALUE_REFERENCES |
| if (x < 0) return boost::make_exceptional_future<int>(std::logic_error("Error")).share(); |
| #else |
| if (x < 0) return boost::make_exceptional(std::logic_error("Error")); |
| #endif |
| //boost::future<int> f1 = boost::async([]() { return x+1; }); |
| boost::shared_future<int> f1 = boost::async(&p1).share(); |
| return f1; |
| } |
| |
| |
| int main() |
| { |
| const int number_of_tests = 100; |
| for (int i=0; i< number_of_tests; i++) |
| try |
| { |
| // { |
| // std::cout << __FILE__ << " "<<__LINE__ << std::endl; |
| // boost::future<int> f = boost::async(boost::launch::async, p1); |
| // std::cout << i << " "<<f.get() << std::endl; |
| // } |
| #if defined BOOST_THREAD_USES_MOVE |
| { |
| std::cout << __FILE__ << " "<< __LINE__ << std::endl; |
| boost::future<void> f = void_compute(); |
| f.get(); |
| } |
| #endif |
| { |
| std::cout << __FILE__ << " "<< __LINE__ << std::endl; |
| boost::future<int> f = compute(-1); |
| f.wait(); |
| } |
| { |
| std::cout << __FILE__ << " "<< __LINE__ << std::endl; |
| boost::future<int> f = compute(0); |
| std::cout << f.get() << std::endl; |
| } |
| { |
| std::cout << __FILE__ << " "<< __LINE__ << std::endl; |
| boost::future<int&> f = compute_ref(0); |
| std::cout << f.get() << std::endl; |
| } |
| #if __cplusplus > 201103L |
| { |
| std::cout << __FILE__ << " "<< __LINE__ << std::endl; |
| int i = 0; |
| boost::future<int&> f = boost::make_ready_future(std::ref(i)); |
| std::cout << f.get() << std::endl; |
| } |
| #endif |
| { |
| std::cout << __FILE__ << " "<< __LINE__ << std::endl; |
| int i = 0; |
| boost::future<int&> f = boost::make_ready_future(boost::ref(i)); |
| std::cout << f.get() << std::endl; |
| } |
| { |
| std::cout << __FILE__ << " "<< __LINE__ << std::endl; |
| const int i = 0; |
| boost::future<int const&> f = boost::make_ready_future(boost::cref(i)); |
| std::cout << f.get() << std::endl; |
| } |
| { |
| std::cout << __FILE__ << " "<< __LINE__ << std::endl; |
| boost::future<int> f = compute(2); |
| std::cout << f.get() << std::endl; |
| } |
| { |
| std::cout << __FILE__ << " "<< __LINE__ << std::endl; |
| boost::shared_future<int> f = shared_compute(0); |
| std::cout << f.get() << std::endl; |
| } |
| } |
| catch (std::exception& ex) |
| { |
| std::cout << "ERRORRRRR "<<ex.what() << "" << std::endl; |
| return 1; |
| } |
| catch (...) |
| { |
| std::cout << "ERRORRRRR "<<"ERRORRRRR exception thrown" << std::endl; |
| return 2; |
| } |
| return 0; |
| } |