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 ()

Detailed Description

Definition at line 18 of file PndLmdThreadPool.h.

Constructor & Destructor Documentation

PndLmdThreadPool() [1/2]

PndLmdThreadPool::PndLmdThreadPool ( )

inline

Definition at line 37 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() [2/2]

PndLmdThreadPool::PndLmdThreadPool ( unsigned int  maxThreads )

inline

Definition at line 44 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::~PndLmdThreadPool ( )

inline

Definition at line 82 of file PndLmdThreadPool.h.

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

Member Function Documentation

dequeue()

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

inline

Definition at line 59 of file PndLmdThreadPool.h.

  {
    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;
  }

enqueue()

void PndLmdThreadPool::enqueue ( job_t  job )

inline

Definition at line 52 of file PndLmdThreadPool.h.

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

wait()

void PndLmdThreadPool::wait ( )

inline

Definition at line 72 of file PndLmdThreadPool.h.

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

---

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

• PndLmdThreadPool.h