]>
Commit | Line | Data |
---|---|---|
7c673cae FG |
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 | #if ! defined BOOST_NO_CXX11_DECLTYPE | |
8 | #define BOOST_RESULT_OF_USE_DECLTYPE | |
9 | #endif | |
10 | ||
11 | ||
12 | #define BOOST_THREAD_VERSION 4 | |
13 | //#define BOOST_THREAD_USES_LOG | |
14 | #define BOOST_THREAD_USES_LOG_THREAD_ID | |
15 | ||
16 | #include <boost/thread/detail/log.hpp> | |
17 | #include <boost/thread/future.hpp> | |
18 | #include <boost/assert.hpp> | |
19 | #include <string> | |
20 | #if defined BOOST_THREAD_PROVIDES_FUTURE_CONTINUATION | |
21 | ||
22 | int p1() | |
23 | { | |
24 | BOOST_THREAD_LOG << "P1" << BOOST_THREAD_END_LOG; | |
25 | return 123; | |
26 | } | |
27 | ||
28 | int p2(boost::future<int> f) | |
29 | { | |
30 | BOOST_THREAD_LOG << "P2<" << BOOST_THREAD_END_LOG; | |
31 | try | |
32 | { | |
33 | return 2 * f.get(); | |
34 | } | |
35 | catch (std::exception& ex) | |
36 | { | |
37 | std::cout << "ERRORRRRR "<<ex.what() << "" << std::endl; | |
38 | BOOST_THREAD_LOG << "ERRORRRRR "<<ex.what() << "" << BOOST_THREAD_END_LOG; | |
39 | BOOST_ASSERT(false); | |
40 | } | |
41 | catch (...) | |
42 | { | |
43 | BOOST_THREAD_LOG << " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG; | |
44 | BOOST_ASSERT(false); | |
45 | } | |
46 | BOOST_THREAD_LOG << "P2>" << BOOST_THREAD_END_LOG; | |
47 | return 0; | |
48 | } | |
49 | int p2s(boost::shared_future<int> f) | |
50 | { | |
51 | BOOST_THREAD_LOG << "<P2S" << BOOST_THREAD_END_LOG; | |
52 | try | |
53 | { | |
54 | return 2 * f.get(); | |
55 | } | |
56 | catch (std::exception& ex) | |
57 | { | |
58 | std::cout << "ERRORRRRR "<<ex.what() << "" << std::endl; | |
59 | BOOST_THREAD_LOG << "ERRORRRRR "<<ex.what() << "" << BOOST_THREAD_END_LOG; | |
60 | BOOST_ASSERT(false); | |
61 | } | |
62 | catch (...) | |
63 | { | |
64 | BOOST_THREAD_LOG << " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG; | |
65 | BOOST_ASSERT(false); | |
66 | } | |
67 | BOOST_THREAD_LOG << "P2S>" << BOOST_THREAD_END_LOG; | |
68 | return 0; | |
69 | } | |
70 | ||
71 | int main() | |
72 | { | |
73 | const int number_of_tests = 100; | |
74 | BOOST_THREAD_LOG << "<MAIN" << BOOST_THREAD_END_LOG; | |
75 | { | |
76 | for (int i=0; i< number_of_tests; i++) | |
77 | try | |
78 | { | |
79 | BOOST_THREAD_LOG << "" << BOOST_THREAD_END_LOG; | |
80 | boost::future<int> f1 = boost::async(&p1); | |
81 | BOOST_THREAD_LOG << "" << BOOST_THREAD_END_LOG; | |
82 | boost::future<int> f2 = f1.then(&p2); | |
83 | BOOST_THREAD_LOG << "" << BOOST_THREAD_END_LOG; | |
84 | (void)f2.get(); | |
85 | BOOST_THREAD_LOG << "" << BOOST_THREAD_END_LOG; | |
86 | } | |
87 | catch (std::exception& ex) | |
88 | { | |
89 | std::cout << "ERRORRRRR "<<ex.what() << "" << std::endl; | |
90 | BOOST_THREAD_LOG << "ERRORRRRR "<<ex.what() << "" << BOOST_THREAD_END_LOG; | |
91 | return 1; | |
92 | } | |
93 | catch (...) | |
94 | { | |
95 | BOOST_THREAD_LOG << " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG; | |
96 | return 2; | |
97 | } | |
98 | } | |
99 | { | |
100 | for (int i=0; i< number_of_tests; i++) | |
101 | try | |
102 | { | |
103 | BOOST_THREAD_LOG << "" << BOOST_THREAD_END_LOG; | |
104 | boost::shared_future<int> f1 = boost::async(&p1).share(); | |
105 | BOOST_THREAD_LOG << "" << BOOST_THREAD_END_LOG; | |
106 | boost::future<int> f2 = f1.then(&p2s); | |
107 | BOOST_THREAD_LOG << "" << BOOST_THREAD_END_LOG; | |
108 | (void)f2.get(); | |
109 | BOOST_THREAD_LOG << "" << BOOST_THREAD_END_LOG; | |
110 | } | |
111 | catch (std::exception& ex) | |
112 | { | |
113 | std::cout << "ERRORRRRR "<<ex.what() << "" << std::endl; | |
114 | BOOST_THREAD_LOG << "ERRORRRRR "<<ex.what() << "" << BOOST_THREAD_END_LOG; | |
115 | return 1; | |
116 | } | |
117 | catch (...) | |
118 | { | |
119 | BOOST_THREAD_LOG << " ERRORRRRR exception thrown" << BOOST_THREAD_END_LOG; | |
120 | return 2; | |
121 | } | |
122 | } | |
123 | BOOST_THREAD_LOG << "MAIN>" << BOOST_THREAD_END_LOG; | |
124 | return 0; | |
125 | } | |
126 | #else | |
127 | ||
128 | int main() | |
129 | { | |
130 | return 0; | |
131 | } | |
132 | #endif |