1 // Copyright (C) 2012-2013 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 #include <boost/config.hpp>
7
8 #if ! defined BOOST_NO_CXX11_DECLTYPE
9 #define BOOST_RESULT_OF_USE_DECLTYPE
10 #endif
11
12
13 #define BOOST_THREAD_VERSION 4
14 //#define BOOST_THREAD_USES_LOG
15 #define BOOST_THREAD_USES_LOG_THREAD_ID
16
17 #include <boost/thread/future.hpp>
18 #include <boost/thread/csbl/vector.hpp>
19 #include <boost/assert.hpp>
20 #include <boost/thread/detail/log.hpp>
21 #include <string>
22 #if defined BOOST_THREAD_PROVIDES_FUTURE_WHEN_ALL_WHEN_ANY
23
24 #ifdef BOOST_MSVC
25 #pragma warning(disable: 4127) // conditional expression is constant
26 #endif
27
p1()28 int p1()
29 {
30 BOOST_THREAD_LOG
31 << "P1" << BOOST_THREAD_END_LOG;
32 boost::this_thread::sleep_for(boost::chrono::seconds(1));
33 return 123;
34 }
p1b()35 int p1b()
36 {
37 BOOST_THREAD_LOG
38 << "P1b" << BOOST_THREAD_END_LOG;
39 boost::this_thread::sleep_for(boost::chrono::seconds(1));
40 return 321;
41 }
42
p2(boost::future<int> f)43 int p2(boost::future<int> f)
44 {
45 BOOST_THREAD_LOG
46 << " P2 " << BOOST_THREAD_END_LOG;
47 try
48 {
49 return 2 * f.get();
50 }
51 catch (std::exception& ex)
52 {
53 BOOST_THREAD_LOG
54 << "ERRORRRRR " << ex.what() << "" << BOOST_THREAD_END_LOG;
55 BOOST_ASSERT(false);
56 }
57 catch (...)
58 {
59 BOOST_THREAD_LOG
60 << " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG;
61 BOOST_ASSERT(false);
62 }
63 BOOST_THREAD_LOG
64 << "P2>" << BOOST_THREAD_END_LOG;
65 return 0;
66
67 }
p2s(boost::shared_future<int> f)68 int p2s(boost::shared_future<int> f)
69 {
70 BOOST_THREAD_LOG
71 << "<P2" << BOOST_THREAD_END_LOG;
72 try
73 {
74 return 2 * f.get();
75 }
76 catch (std::exception& ex)
77 {
78 BOOST_THREAD_LOG
79 << "ERRORRRRR " << ex.what() << "" << BOOST_THREAD_END_LOG;
80 BOOST_ASSERT(false);
81 }
82 catch (...)
83 {
84 BOOST_THREAD_LOG
85 << " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG;
86 BOOST_ASSERT(false);
87 }
88 BOOST_THREAD_LOG
89 << "P2>" << BOOST_THREAD_END_LOG;
90 return 0;
91 }
92
main()93 int main()
94 {
95 BOOST_THREAD_LOG
96 << "<MAIN" << BOOST_THREAD_END_LOG;
97 {
98 try
99 {
100 {
101 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
102 boost::future<boost::csbl::tuple<> > all0 = boost::when_all();
103 BOOST_THREAD_LOG
104 << BOOST_THREAD_END_LOG;
105 }
106 {
107 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
108 boost::future<int> f1 = boost::async(boost::launch::async, &p1);
109 boost::future<boost::csbl::tuple<boost::future<int> > > all = boost::when_all(boost::move(f1));
110 boost::csbl::tuple<boost::future<int> > res = all.get();
111 BOOST_THREAD_LOG
112 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
113 }
114 #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
115 {
116 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
117 boost::future<int> f1 = boost::async(boost::launch::deferred, &p1);
118 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
119 boost::future<boost::csbl::tuple<boost::future<int> > > all = boost::when_all(boost::move(f1));
120 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
121 boost::csbl::tuple<boost::future<int> > res = all.get();
122 BOOST_THREAD_LOG
123 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
124 }
125 #endif
126 {
127 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
128 boost::future<int> f1 = boost::make_ready_future(1);
129 boost::future<boost::csbl::tuple<boost::future<int> > > all = boost::when_all(boost::move(f1));
130 boost::csbl::tuple<boost::future<int> > res = all.get();
131 BOOST_THREAD_LOG
132 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
133 }
134 {
135 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
136 boost::future<int> f1 = boost::async(boost::launch::async, &p1);
137 boost::future<int> f2 = boost::async(boost::launch::async, &p1b);
138 boost::future<boost::csbl::tuple<boost::future<int>,boost::future<int> > > all = boost::when_all(boost::move(f1), boost::move(f2));
139 //(void) all.wait();
140 boost::csbl::tuple<boost::future<int>,boost::future<int> > res = all.get();
141 BOOST_THREAD_LOG
142 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
143 BOOST_THREAD_LOG
144 << boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
145 }
146 {
147 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
148 boost::future<int> f1 = boost::async(boost::launch::async, &p1);
149 boost::future<std::string> f2 = boost::make_ready_future(std::string("nnnnnnn"));;
150 boost::future<boost::csbl::tuple<boost::future<int>, boost::future<std::string> > > all = boost::when_all(boost::move(f1), boost::move(f2));
151 //(void) all.wait();
152 boost::csbl::tuple<boost::future<int>, boost::future<std::string> > res = all.get();
153 BOOST_THREAD_LOG
154 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
155 BOOST_THREAD_LOG
156 << boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
157 }
158 {
159 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
160 boost::csbl::vector<boost::future<int> > v;
161 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
162 v.push_back(boost::async(boost::launch::async, &p1));
163 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
164 v.push_back(boost::async(boost::launch::async, &p1b));
165 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
166 boost::future<boost::csbl::vector<boost::future<int> > > all = boost::when_all(v.begin(), v.end());
167 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
168 boost::csbl::vector<boost::future<int> > res = all.get();
169 BOOST_THREAD_LOG
170 << res[0].get() <<" " << BOOST_THREAD_END_LOG;
171 BOOST_THREAD_LOG
172 << res[1].get() <<" " << BOOST_THREAD_END_LOG;
173 }
174 }
175 catch (std::exception& ex)
176 {
177 BOOST_THREAD_LOG
178 << "ERRORRRRR " << ex.what() << "" << BOOST_THREAD_END_LOG;
179 return 1;
180 }
181 catch (...)
182 {
183 BOOST_THREAD_LOG
184 << " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG;
185 return 2;
186 }
187 }
188 {
189 try
190 {
191 {
192 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
193 boost::future<boost::csbl::tuple<> > all0 = boost::when_any();
194 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
195 }
196 {
197 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
198 boost::future<int> f1 = boost::async(boost::launch::async, &p1);
199 boost::future<boost::csbl::tuple<boost::future<int> > > all = boost::when_any(boost::move(f1));
200 boost::csbl::tuple<boost::future<int> > res = all.get();
201 BOOST_THREAD_LOG
202 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
203 }
204 #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
205 {
206 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
207 boost::future<int> f1 = boost::async(boost::launch::deferred, &p1);
208 boost::future<boost::csbl::tuple<boost::future<int> > > all = boost::when_any(boost::move(f1));
209 boost::csbl::tuple<boost::future<int> > res = all.get();
210 BOOST_THREAD_LOG
211 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
212 }
213 #endif
214 {
215 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
216 boost::future<int> f1 = boost::async(boost::launch::async, &p1);
217 boost::future<int> f2 = boost::async(boost::launch::async, &p1b);
218 boost::future<boost::csbl::tuple<boost::future<int>,boost::future<int> > > all = boost::when_any(boost::move(f1), boost::move(f2));
219 boost::csbl::tuple<boost::future<int>,boost::future<int> > res = all.get();
220 BOOST_THREAD_LOG
221 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
222 BOOST_THREAD_LOG
223 << boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
224 }
225 {
226 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
227 boost::future<int> f1 = boost::make_ready_future(1);
228 boost::future<int> f2 = boost::async(boost::launch::async, &p1b);
229 boost::future<boost::csbl::tuple<boost::future<int>,boost::future<int> > > all = boost::when_any(boost::move(f1), boost::move(f2));
230 boost::csbl::tuple<boost::future<int>,boost::future<int> > res = all.get();
231 BOOST_THREAD_LOG
232 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
233 BOOST_THREAD_LOG
234 << boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
235 }
236 {
237 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
238 boost::future<std::string> f1 = boost::make_ready_future(std::string("aaaa"));
239 boost::future<int> f2 = boost::async(boost::launch::async, &p1b);
240 boost::future<boost::csbl::tuple<boost::future<std::string>,boost::future<int> > > all = boost::when_any(boost::move(f1), boost::move(f2));
241 boost::csbl::tuple<boost::future<std::string>,boost::future<int> > res = all.get();
242 BOOST_THREAD_LOG
243 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
244 BOOST_THREAD_LOG
245 << boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
246 }
247 {
248 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
249 boost::future<int> f2 = boost::make_ready_future(1);
250 boost::future<int> f1 = boost::async(boost::launch::async, &p1b);
251 boost::future<boost::csbl::tuple<boost::future<int>,boost::future<int> > > all = boost::when_any(boost::move(f1), boost::move(f2));
252 boost::csbl::tuple<boost::future<int>,boost::future<int> > res = all.get();
253 BOOST_THREAD_LOG
254 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
255 BOOST_THREAD_LOG
256 << boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
257 }
258 #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD)
259 {
260 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
261 boost::future<int> f1 = boost::async(boost::launch::deferred, &p1);
262 boost::future<int> f2 = boost::async(boost::launch::async, &p1b);
263 boost::future<boost::csbl::tuple<boost::future<int>,boost::future<int> > > all = boost::when_any(boost::move(f1), boost::move(f2));
264 boost::csbl::tuple<boost::future<int>,boost::future<int> > res = all.get();
265 BOOST_THREAD_LOG
266 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
267 BOOST_THREAD_LOG
268 << boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
269 }
270 {
271 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
272 boost::future<int> f1 = boost::async(boost::launch::async, &p1);
273 boost::future<int> f2 = boost::async(boost::launch::deferred, &p1b);
274 boost::future<boost::csbl::tuple<boost::future<int>,boost::future<int> > > all = boost::when_any(boost::move(f1), boost::move(f2));
275 boost::csbl::tuple<boost::future<int>,boost::future<int> > res = all.get();
276 BOOST_THREAD_LOG
277 << boost::csbl::get<0>(res).get() <<" " << BOOST_THREAD_END_LOG;
278 BOOST_THREAD_LOG
279 << boost::csbl::get<1>(res).get() <<" " << BOOST_THREAD_END_LOG;
280 }
281 #endif
282 {
283 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
284 boost::csbl::vector<boost::future<int> > v;
285 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
286 v.push_back(boost::async(boost::launch::async, &p1));
287 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
288 v.push_back(boost::async(boost::launch::async, &p1b));
289 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
290 boost::future<boost::csbl::vector<boost::future<int> > > all = boost::when_any(v.begin(), v.end());
291 BOOST_THREAD_LOG << BOOST_THREAD_END_LOG;
292 boost::csbl::vector<boost::future<int> > res = all.get();
293 BOOST_THREAD_LOG
294 << res[0].get() <<" " << BOOST_THREAD_END_LOG;
295 BOOST_THREAD_LOG
296 << res[1].get() <<" " << BOOST_THREAD_END_LOG;
297 }
298 }
299 catch (std::exception& ex)
300 {
301 BOOST_THREAD_LOG
302 << "ERRORRRRR " << ex.what() << "" << BOOST_THREAD_END_LOG;
303 return 1;
304 }
305 catch (...)
306 {
307 BOOST_THREAD_LOG
308 << " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG;
309 return 2;
310 }
311 }
312 BOOST_THREAD_LOG
313 << "MAIN>" << BOOST_THREAD_END_LOG;
314 return 0;
315 }
316 #else
317 #include <boost/thread/csbl/vector.hpp>
318 using namespace boost;
319
f(boost::csbl::vector<future<int>> &,BOOST_THREAD_RV_REF (future<int>))320 void f( boost::csbl::vector<future<int> > &//vec
321 , BOOST_THREAD_RV_REF(future<int>) //f
322 ) {
323 }
main()324 int main()
325 {
326 boost::csbl::vector<future<int> > vec;
327 f(vec, make_ready_future(0));
328 return 0;
329 }
330 #endif
331