#include <threadhelp.h>

Inheritance diagram for Pol::threadhelp::DynTaskThreadPool:

Classes
class	PoolWorker

Public Member Functions
	DynTaskThreadPool (const std::string &name)
	Creates a dynamic threadpool of workers. if no idle worker is found creates a new worker thread blocks on deconstruction eg: DynTaskThreadPool workers; for (....) workers.push([&](){dosomework();});. More...

	~DynTaskThreadPool ()

std::future< bool >	checked_push (const msg &msg)
	returns a future which will be set once the msg is processed More...

void	push (const msg &msg)
	simply fire and forget only the deconstructor ensures the msg to be finished More...

size_t	threadpoolsize () const

Protected Attributes
std::atomic< bool >	_done

Private Types
typedef std::function< void()>	msg

typedef Clib::message_queue< msg >	msg_queue

Private Member Functions
void	create_thread ()

Private Attributes
msg_queue	_msg_queue

std::string	_name

std::mutex	_pool_mutex

std::vector< std::unique_ptr< PoolWorker > >	_threads

Friends
class	PoolWorker

Detailed Description

Definition at line 98 of file threadhelp.h.

Member Typedef Documentation

typedef std::function<void()> Pol::threadhelp::DynTaskThreadPool::msg

private

Definition at line 103 of file threadhelp.h.

typedef Clib::message_queue<msg> Pol::threadhelp::DynTaskThreadPool::msg_queue

private

Definition at line 104 of file threadhelp.h.

Constructor & Destructor Documentation

Pol::threadhelp::DynTaskThreadPool::DynTaskThreadPool ( const std::string & name )

Creates a dynamic threadpool of workers. if no idle worker is found creates a new worker thread blocks on deconstruction eg: DynTaskThreadPool workers; for (....) workers.push([&](){dosomework();});.

Definition at line 505 of file threadhelp.cpp.

Pol::threadhelp::DynTaskThreadPool::~DynTaskThreadPool ( )

Definition at line 531 of file threadhelp.cpp.

References _done, _msg_queue, _threads, Pol::Clib::message_queue< Message >::cancel(), and Pol::Clib::message_queue< Message >::push().