PndLmdThreadPool Class Reference

#include <PndLmdThreadPool.h>

Public Member Functions
	PndLmdThreadPool ()
	PndLmdThreadPool (unsigned int maxThreads)
void	enqueue (job_t job)
boost::optional< job_t >	dequeue ()
void	wait ()
	~PndLmdThreadPool ()

Private Types
typedef boost::function< void()>	job_t

Static Private Member Functions
static void	worker_thread (PndLmdThreadPool &q)

Private Attributes
boost::mutex	mx
boost::condition_variable	cv
std::deque< job_t >	_queue
boost::thread_group	pool
boost::atomic_bool	shutdown

Detailed Description

Definition at line 18 of file PndLmdThreadPool.h.

Member Typedef Documentation

typedef boost::function<void()> PndLmdThreadPool::job_t

private

Definition at line 23 of file PndLmdThreadPool.h.

Constructor & Destructor Documentation

PndLmdThreadPool::PndLmdThreadPool ( )

inline

Definition at line 36 of file PndLmdThreadPool.h.

References i.

                           :
                        shutdown(false) {
                for (unsigned i = 0; i < boost::thread::hardware_concurrency(); ++i)
                        pool.create_thread(boost::bind(worker_thread, boost::ref(*this)));
        }

PndLmdThreadPool::PndLmdThreadPool ( unsigned int  maxThreads )

inline

Definition at line 43 of file PndLmdThreadPool.h.

References i.

                                                  :
                        shutdown(false) {
                if (maxThreads > boost::thread::hardware_concurrency() || maxThreads == 0) maxThreads =
                    boost::thread::hardware_concurrency();
                for (unsigned i = 0; i < maxThreads; ++i)
                        pool.create_thread(boost::bind(worker_thread, boost::ref(*this)));
        }

PndLmdThreadPool::~PndLmdThreadPool ( )

inline

Definition at line 77 of file PndLmdThreadPool.h.

                            {
                shutdown = true;
                {
                        boost::lock_guard<boost::mutex> lk(mx);
                        cv.notify_all();
                }
                pool.join_all();
        }

Member Function Documentation

boost::optional<job_t> PndLmdThreadPool::dequeue ( )

inline

Definition at line 57 of file PndLmdThreadPool.h.

Referenced by worker_thread().

                                       {
                boost::unique_lock<boost::mutex> lk(mx);
                namespace phx = boost::phoenix;
                cv.wait(lk, phx::ref(shutdown) || !phx::empty(phx::ref(_queue)));
                if (_queue.empty()) return boost::none;
                job_t job = _queue.front();
                _queue.pop_front();
                return job;
        }

void PndLmdThreadPool::enqueue ( job_t  job )

inline

Definition at line 51 of file PndLmdThreadPool.h.

Referenced by PndLmdAlignManager::addPairAndStartAligner(), PndLmdAlignManager::readPairsFromBinaryFilesAndAlign(), and PndLmdAlignManager::waitForCompletion().

                                {
                boost::lock_guard<boost::mutex> lk(mx);
                _queue.push_back(job);
                cv.notify_one();
        }

void PndLmdThreadPool::wait ( )

inline

Definition at line 68 of file PndLmdThreadPool.h.

Referenced by PndLmdAlignManager::waitForCompletion().

                    {
                shutdown = true;
                {
                        boost::lock_guard<boost::mutex> lk(mx);
                        cv.notify_all();
                }
                pool.join_all();
        }

static void PndLmdThreadPool::worker_thread ( PndLmdThreadPool &  q )

inlinestaticprivate

Definition at line 29 of file PndLmdThreadPool.h.

References dequeue().

                                                       {
                while (boost::optional<job_t> job = q.dequeue())
                        (*job)();
        }

Member Data Documentation

std::deque<job_t> PndLmdThreadPool::_queue

private

Definition at line 24 of file PndLmdThreadPool.h.

boost::condition_variable PndLmdThreadPool::cv

private

Definition at line 21 of file PndLmdThreadPool.h.

boost::mutex PndLmdThreadPool::mx

private

Definition at line 20 of file PndLmdThreadPool.h.

boost::thread_group PndLmdThreadPool::pool

private

Definition at line 26 of file PndLmdThreadPool.h.

boost::atomic_bool PndLmdThreadPool::shutdown

private

Definition at line 28 of file PndLmdThreadPool.h.

---

The documentation for this class was generated from the following file:

• PndLmdThreadPool.h