]>
Commit | Line | Data |
---|---|---|
7c673cae FG |
1 | // Copyright (C) 2010 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 2 | |
7 | ||
8 | #include <iostream> | |
9 | #include <boost/thread/thread_only.hpp> | |
10 | ||
11 | class Worker | |
12 | { | |
13 | public: | |
14 | ||
15 | Worker() | |
16 | { | |
17 | // the thread is not-a-thread until we call start() | |
18 | } | |
19 | ||
20 | void start(int N) | |
21 | { | |
22 | // std::cout << "start\n"; | |
23 | m_Thread = boost::thread(&Worker::processQueue, this, N); | |
24 | // std::cout << "started\n"; | |
25 | } | |
26 | ||
27 | void join() | |
28 | { | |
29 | m_Thread.join(); | |
30 | } | |
31 | ||
32 | void processQueue(unsigned N) | |
33 | { | |
b32b8144 | 34 | unsigned ms = N * 1000; |
7c673cae FG |
35 | boost::posix_time::milliseconds workTime(ms); |
36 | ||
37 | // std::cout << "Worker: started, will work for " | |
38 | // << ms << "ms" | |
39 | // << std::endl; | |
40 | ||
41 | // We're busy, honest! | |
42 | boost::this_thread::sleep(workTime); | |
43 | ||
44 | // std::cout << "Worker: completed" << std::endl; | |
45 | } | |
46 | ||
47 | private: | |
48 | ||
49 | boost::thread m_Thread; | |
50 | }; | |
51 | ||
52 | int main() | |
53 | { | |
54 | // std::cout << "main: startup" << std::endl; | |
55 | ||
56 | Worker worker; | |
57 | ||
58 | // std::cout << "main: create worker" << std::endl; | |
59 | ||
60 | worker.start(3); | |
61 | ||
62 | // std::cout << "main: waiting for thread" << std::endl; | |
63 | ||
64 | worker.join(); | |
65 | ||
66 | // std::cout << "main: done" << std::endl; | |
67 | ||
68 | return 0; | |
69 | } |