Class that defines a pool of threads that will execute scheduled tasks (see LAMAThreadTask). More...

Public Member Functions
	LAMAThreadPool (int size)
	Create a new thread pool with a certain number of threads.
boost::shared_ptr< LAMAThreadTask >	schedule (boost::function< void()> work, int numOmpThreads=0)
	Schedules a new function that will be executed by available free thread.
void	wait (boost::shared_ptr< LAMAThreadTask > task)
	Wait on completion of a task.
	~LAMAThreadPool ()
	Destructor shuts down and deletes all threads of the pool.
Private Types
enum	WorkerState { WORKING, WAITING }
Private Member Functions
void	worker (int id)
	Method that will be run by the worker threads.
	LAMA_LOG_DECL_STATIC_LOGGER (logger)
Private Attributes
unsigned int	mTaskId
int	mMaxSize
std::vector< boost::thread * >	mThreads
std::queue< boost::shared_ptr < LAMAThreadTask > >	mTaskQueue
boost::condition	mNotifyFinished
boost::condition	mNotifyTask
boost::mutex	mTaskQueueMutex
boost::mutex	mNotifyFinishMutex
WorkerState	mWorkerState

Detailed Description

Class that defines a pool of threads that will execute scheduled tasks (see LAMAThreadTask).

The main advantage of this class is that creation of running threads is only done once. Non-busy threads will wait on notification for new tasks.

Note: tasks will be handled by shared pointers so task data might be freed either here or at its creation.

Member Enumeration Documentation

Enumerator:

WORKING
WAITING

lama::LAMAThreadPool::LAMAThreadPool ( int size )

Create a new thread pool with a certain number of threads.

lama::LAMAThreadPool::~LAMAThreadPool ( )

Destructor shuts down and deletes all threads of the pool.

lama::LAMAThreadPool::LAMA_LOG_DECL_STATIC_LOGGER ( logger ) [private]

boost::shared_ptr< LAMAThreadTask > lama::LAMAThreadPool::schedule	(	boost::function< void()>	work,
		int	numOmpThreads = `0`
	)

Schedules a new function that will be executed by available free thread.

Parameters:

[in]	work	is function to be executed by available thread
[in]	numOmpThreads	number of openmp threads the task should use (if numOmpThreads == 0 omp_get_max_threads() is used)