| 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 | { |
|---|
| 34 | unsigned ms = N * 1000; |
|---|
| 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(rel_time: 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(N: 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 | } |
|---|
| 70 | |
|---|
