70 lines
1.3 KiB
C++
70 lines
1.3 KiB
C++
// Copyright (C) 2010 Vicente Botet
|
|
//
|
|
// Distributed under the Boost Software License, Version 1.0. (See accompanying
|
|
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
|
|
|
|
#define BOOST_THREAD_VERSION 2
|
|
|
|
#include <iostream>
|
|
#include <boost/thread/thread_only.hpp>
|
|
|
|
class Worker
|
|
{
|
|
public:
|
|
|
|
Worker()
|
|
{
|
|
// the thread is not-a-thread until we call start()
|
|
}
|
|
|
|
void start(int N)
|
|
{
|
|
// std::cout << "start\n";
|
|
m_Thread = boost::thread(&Worker::processQueue, this, N);
|
|
// std::cout << "started\n";
|
|
}
|
|
|
|
void join()
|
|
{
|
|
m_Thread.join();
|
|
}
|
|
|
|
void processQueue(unsigned N)
|
|
{
|
|
unsigned ms = N * 1000;
|
|
boost::posix_time::milliseconds workTime(ms);
|
|
|
|
// std::cout << "Worker: started, will work for "
|
|
// << ms << "ms"
|
|
// << std::endl;
|
|
|
|
// We're busy, honest!
|
|
boost::this_thread::sleep(workTime);
|
|
|
|
// std::cout << "Worker: completed" << std::endl;
|
|
}
|
|
|
|
private:
|
|
|
|
boost::thread m_Thread;
|
|
};
|
|
|
|
int main()
|
|
{
|
|
// std::cout << "main: startup" << std::endl;
|
|
|
|
Worker worker;
|
|
|
|
// std::cout << "main: create worker" << std::endl;
|
|
|
|
worker.start(3);
|
|
|
|
// std::cout << "main: waiting for thread" << std::endl;
|
|
|
|
worker.join();
|
|
|
|
// std::cout << "main: done" << std::endl;
|
|
|
|
return 0;
|
|
}
|