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 | #define BOOST_THREAD_VERSION 4 |
7 | #include <iostream> |
8 | #include <fstream> |
9 | #include <stdio.h> |
10 | #include <boost/function.hpp> |
11 | #include <boost/make_shared.hpp> |
12 | #include <boost/shared_ptr.hpp> |
13 | #include <boost/bind/bind.hpp> |
14 | #include <boost/asio.hpp> |
15 | #include <boost/thread.hpp> |
16 | #include <boost/thread/future.hpp> |
17 | |
18 | #if defined(BOOST_THREAD_PROVIDES_VARIADIC_THREAD) |
19 | #define EXAMPLE_1 |
20 | #define EXAMPLE_2 |
21 | #define EXAMPLE_3 |
22 | #define EXAMPLE_4 |
23 | #define EXAMPLE_5 |
24 | #define EXAMPLE_6 |
25 | #define EXAMPLE_7 |
26 | #else |
27 | #define EXAMPLE_1 |
28 | #define EXAMPLE_2 |
29 | //#define EXAMPLE_3 |
30 | //#define EXAMPLE_4 |
31 | //#define EXAMPLE_5 |
32 | //#define EXAMPLE_6 |
33 | //#define EXAMPLE_7 |
34 | #endif |
35 | |
36 | // Test functions |
37 | |
38 | int int_no_params() |
39 | { |
40 | return 42; |
41 | } |
42 | |
43 | int int_with_params(int i) |
44 | { |
45 | return i; |
46 | } |
47 | |
48 | std::string string_no_params() |
49 | { |
50 | return std::string("forty two" ); |
51 | } |
52 | |
53 | std::string string_with_params(std::string& ans) |
54 | { |
55 | return ans; |
56 | } |
57 | |
58 | int main(int /*argc*/, char ** /*argv[]*/) |
59 | { |
60 | std::string ans("forty two" ); |
61 | |
62 | #if defined EXAMPLE_1 |
63 | //! Compiles and produces correct result. |
64 | { |
65 | boost::packaged_task<int()> example(int_no_params); |
66 | boost::future<int> f = example.get_future(); |
67 | boost::thread task(boost::move(t&: example)); |
68 | int answer = f.get(); |
69 | std::cout << "Answer to life and whatnot, in English: " << answer << std::endl; |
70 | task.join(); |
71 | } |
72 | #endif |
73 | |
74 | #if defined EXAMPLE_2 |
75 | //! Compiles and produces correct result. |
76 | { |
77 | boost::packaged_task<std::string()> example(string_no_params); |
78 | boost::future<std::string> f = example.get_future(); |
79 | boost::thread task(boost::move(t&: example)); |
80 | std::string answer = f.get(); |
81 | std::cout << "string_no_params: " << answer << std::endl; |
82 | task.join(); |
83 | } |
84 | |
85 | #endif |
86 | |
87 | #if defined EXAMPLE_3 |
88 | //! Doesn't compile in C++03. |
89 | //! error: variable âboost::packaged_task<std::basic_string<char>(std::basic_string<char>&)> exampleâ has initializer but incomplete type |
90 | |
91 | { |
92 | boost::packaged_task<std::string(std::string&)> example(string_with_params); |
93 | boost::future<std::string> f = example.get_future(); |
94 | example(ans); |
95 | std::string answer = f.get(); |
96 | std::cout << "string_with_params: " << answer << std::endl; |
97 | } |
98 | |
99 | #endif |
100 | |
101 | #if defined EXAMPLE_4 |
102 | //! Doesn't compile in C++11 |
103 | // In file included from test_9303.cpp:10: |
104 | // In file included from ../../../boost/thread.hpp:13: |
105 | // In file included from ../../../boost/thread/thread.hpp:12: |
106 | // In file included from ../../../boost/thread/thread_only.hpp:22: |
107 | // ../../../boost/thread/detail/thread.hpp:76:15: error: no matching function for call to 'invoke' |
108 | // invoke(std::move(std::get<0>(fp)), std::move(std::get<Indices>(fp))...); |
109 | // ^~~~~~ |
110 | |
111 | { |
112 | boost::packaged_task<std::string(std::string&)> example(string_with_params); |
113 | boost::future<std::string> f = example.get_future(); |
114 | boost::thread task(boost::move(t&: example), boost::ref(t&: ans)); |
115 | std::string answer = f.get(); |
116 | std::cout << "string_with_params: " << answer << std::endl; |
117 | task.join(); |
118 | } |
119 | #endif |
120 | |
121 | #if defined EXAMPLE_5 |
122 | //! Doesn't compile in C++03, C++11 only. |
123 | //! error: extended initializer lists only available with -std=c++11 or -std=gnu++11 [-Werror] |
124 | { |
125 | boost::packaged_task<std::string(std::string&)> example |
126 | { boost::bind(f: &string_with_params, a1: ans) }; |
127 | boost::future<std::string> f = example.get_future(); |
128 | boost::thread task(boost::move(t&: example), boost::ref(t&: ans)); |
129 | std::string answer = f.get(); |
130 | std::cout << "string_with_params: " << answer << std::endl; |
131 | task.join(); |
132 | } |
133 | #endif |
134 | |
135 | #if defined EXAMPLE_6 |
136 | //! Doesn't compile in C++03, C++11 only. |
137 | // packagedTestTest.cpp:94:43: error: invalid use of incomplete type ‘class boost::packaged_task<std::basic_string<char>(std::basic_string<char>&)>’ |
138 | // packagedTestTest.cpp:95:37: error: incomplete type ‘task_t {aka boost::packaged_task<std::basic_string<char>(std::basic_string<char>&)>}’ used in nested name specifier |
139 | // boost/thread/future.hpp:1320:11: error: declaration of ‘class boost::packaged_task<std::basic_string<char>(std::basic_string<char>&)>’ |
140 | { |
141 | //typedef boost::packaged_task<std::string(std::string&)> task_t; |
142 | typedef boost::packaged_task<std::string()> task_t; |
143 | boost::shared_ptr<task_t> example = boost::make_shared<task_t>(args: boost::bind(f: &string_with_params, a1: boost::ref(t&: ans))); |
144 | boost::future<std::string> f = example->get_future(); |
145 | boost::thread task(boost::bind(f: &task_t::operator(), a1: example)); |
146 | std::string answer = f.get(); |
147 | std::cout << "string_with_params: " << answer << std::endl; |
148 | task.join(); |
149 | } |
150 | #endif |
151 | |
152 | #if defined EXAMPLE_7 |
153 | //! Doesn't compile in C++03, C++11 only. |
154 | // packagedTestTest.cpp:94:43: error: invalid use of incomplete type ‘class boost::packaged_task<std::basic_string<char>(std::basic_string<char>&)>’ |
155 | // packagedTestTest.cpp:95:37: error: incomplete type ‘task_t {aka boost::packaged_task<std::basic_string<char>(std::basic_string<char>&)>}’ used in nested name specifier |
156 | // boost/thread/future.hpp:1320:11: error: declaration of ‘class boost::packaged_task<std::basic_string<char>(std::basic_string<char>&)>’ |
157 | { |
158 | boost::asio::io_service io_service; |
159 | boost::thread_group threads; |
160 | boost::asio::io_service::work work(io_service); |
161 | |
162 | for (int i = 0; i < 3; ++i) |
163 | { |
164 | threads.create_thread(threadfunc: boost::bind(f: &boost::asio::io_service::run, |
165 | a1: &io_service)); |
166 | } |
167 | typedef boost::packaged_task<std::string()> task_t; |
168 | boost::shared_ptr<task_t> example = boost::make_shared<task_t>(args: boost::bind(f: &string_with_params, a1: ans)); |
169 | boost::future<std::string> f = example->get_future(); |
170 | io_service.post(handler: boost::bind(f: &task_t::operator(), a1: example)); |
171 | std::string answer = f.get(); |
172 | std::cout << "string_with_params: " << answer << std::endl; |
173 | threads.join_all(); |
174 | } |
175 | #endif |
176 | return 0; |
177 | } |
178 | |