27 #include "WThreadedFunction.h"
Class to encapsulate boost::condition_variable_any.
ReadTicket getReadTicket() const
Returns a ticket to get read access to the contained data.
WriteTicket getWriteTicket(bool suppressNotify=false) const
Returns a ticket to get write access to the contained data.
std::shared_ptr< WCondition > m_doneCondition
a condition that gets notified when the work is complete
std::shared_ptr< WCondition > getThreadsDoneCondition()
Returns a condition that gets fired when all threads have finished.
WThreadedFunctionStatus status()
Get the status of the threads.
boost::function< void(WException const &) > ExceptionFunction
a type for exception callbacks
ExceptionSignal m_exceptionSignal
a signal for exceptions
WThreadedFunctionBase()
Standard constructor.
void subscribeExceptionSignal(ExceptionFunction func)
Subscribe a function to an exception signal.
virtual ~WThreadedFunctionBase()
Destroys the thread pool and stops all threads, if any one of them is still running.
WSharedObject< WThreadedFunctionStatus > m_status
the current status