1 // Copyright (C) 2014 Vicente Botet
2 //
3 // Distributed under the Boost Software License, Version 1.0. (See accompanying
4 // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
5
6 // <boost/thread/future.hpp>
7
8 // class future<R>
9
10 // template<typename F>
11 // auto then(F&& func) -> future<decltype(func(*this))>;
12
13 #define BOOST_THREAD_VERSION 5
14 //#define BOOST_THREAD_USES_LOG
15 #define BOOST_THREAD_USES_LOG_THREAD_ID
16 #include <boost/thread/detail/log.hpp>
17
18 #include <boost/thread/future.hpp>
19 #include <boost/thread/executors/basic_thread_pool.hpp>
20 #include <boost/thread/executor.hpp>
21 #include <boost/detail/lightweight_test.hpp>
22 #include <cassert>
23
24 #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION
25
26 #ifdef BOOST_MSVC
27 #pragma warning(disable: 4127) // conditional expression is constant
28 #endif
29
p1()30 int p1()
31 {
32 BOOST_THREAD_LOG << "p1 < " << BOOST_THREAD_END_LOG;
33 boost::this_thread::sleep_for(boost::chrono::milliseconds(500));
34 BOOST_THREAD_LOG << "p1 >" << BOOST_THREAD_END_LOG;
35 return 1;
36 }
37
p2(boost::future<int> f)38 int p2(boost::future<int> f)
39 {
40 assert(f.is_ready());
41 BOOST_THREAD_LOG << "p2 <" << &f << BOOST_THREAD_END_LOG;
42 BOOST_TEST(f.valid());
43 int i = f.get();
44 boost::this_thread::sleep_for(boost::chrono::milliseconds(500));
45 BOOST_THREAD_LOG << "p2 <" << &f << BOOST_THREAD_END_LOG;
46 return 2 * i;
47 }
48
p3(boost::future<int> f)49 void p3(boost::future<int> f)
50 {
51 assert(f.is_ready());
52 BOOST_THREAD_LOG << "p3 <" << &f << BOOST_THREAD_END_LOG;
53 BOOST_TEST(f.valid());
54 int i = f.get();
55 boost::this_thread::sleep_for(boost::chrono::milliseconds(500));
56 BOOST_THREAD_LOG << "p3 <" << &f << " " <<i << BOOST_THREAD_END_LOG;
57 return;
58 }
59
main()60 int main()
61 {
62 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
63 {
64 boost::basic_thread_pool ex(1);
65 boost::future<int> f1 = boost::async(boost::launch::async, &p1);
66 BOOST_TEST(f1.valid());
67 boost::future<int> f2 = f1.then(ex, &p2);
68 BOOST_TEST(f2.valid());
69 BOOST_TEST(! f1.valid());
70 try
71 {
72 BOOST_TEST(f2.get()==2);
73 }
74 catch (std::exception& ex)
75 {
76 BOOST_THREAD_LOG << "ERRORRRRR "<<ex.what() << "" << BOOST_THREAD_END_LOG;
77 BOOST_TEST(false);
78 }
79 catch (...)
80 {
81 BOOST_THREAD_LOG << " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG;
82 BOOST_TEST(false);
83 }
84 }
85 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
86 {
87 boost::basic_thread_pool ex(1);
88 boost::future<int> f1 = boost::async(boost::launch::async, &p1);
89 BOOST_TEST(f1.valid());
90 boost::future<void> f2 = f1.then(ex, &p3);
91 BOOST_TEST(f2.valid());
92 try
93 {
94 f2.wait();
95 }
96 catch (std::exception& ex)
97 {
98 BOOST_THREAD_LOG << "ERRORRRRR "<<ex.what() << "" << BOOST_THREAD_END_LOG;
99 BOOST_TEST(false);
100 }
101 catch (...)
102 {
103 BOOST_THREAD_LOG << " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG;
104 BOOST_TEST(false);
105 }
106 }
107 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
108 {
109 boost::basic_thread_pool ex(1);
110 boost::future<int> f2 = boost::async(p1).then(ex, &p2);
111 BOOST_TEST(f2.get()==2);
112 }
113 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
114 {
115 boost::basic_thread_pool ex(1);
116 boost::future<int> f1 = boost::async(p1);
117 boost::future<int> f21 = f1.then(ex, &p2);
118 boost::future<int> f2= f21.then(ex, &p2);
119 BOOST_TEST(f2.get()==4);
120 }
121 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
122 {
123 boost::basic_thread_pool ex(1);
124 boost::future<int> f1 = boost::async(p1);
125 boost::future<int> f21 = f1.then(ex, &p2);
126 boost::future<int> f2= f21.then(&p2);
127 BOOST_TEST(f2.get()==4);
128 }
129 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
130 {
131 boost::basic_thread_pool ex(1);
132 boost::future<int> f1 = boost::async(p1);
133 boost::future<int> f2= f1.then(&p2).then(ex, &p2);
134 BOOST_TEST(f2.get()==4);
135 }
136 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
137 {
138 boost::basic_thread_pool ex(1);
139 boost::future<int> f2 = boost::async(p1).then(ex, &p2).then(ex, &p2);
140 BOOST_TEST(f2.get()==4);
141 }
142
143 return boost::report_errors();
144 }
145
146 #else
147
main()148 int main()
149 {
150 return 0;
151 }
152 #endif
153