Public Member Functions | |
TaskWorkPool (Messaging::MessageQueue< Messages::ITaskPoolMessage * > &poolMessageQueue, Messaging::MessageQueue< Messages::ITaskMessage * > &messageQueue, std::vector< ITaskWorkerRunner * > &workers) | |
void | QueueWork (WorkItem *workItem) |
TaskWorkPoolState::Values | GetState () const |
void | Start () |
void | Stop () |
void | Shutdown () |
void | OnMessageHandled (Messages::ITaskPoolMessage *message) |
bool | HandleMessage (const Messages::WorkCompleteMessage &workCompleteMessage) |
bool | HandleMessage (const Messages::WorkerStoppedMessage &workerStoppedMessage) |
void | Flush () |
Public Member Functions inherited from Eegeo::Messaging::ActiveObject< Messages::ITaskPoolMessage *, Messages::ITaskPoolMessageDispatcher > | |
ActiveObject (MessageQueue< Messages::ITaskPoolMessage * > &messageQueue) | |
void | SendMessage (Messages::ITaskPoolMessage *message) |
bool | ProcessAllAvailableMessages () |
bool | WaitAndProcessSingleMessage () |
virtual void | OnMessageHandled (Messages::ITaskPoolMessage *message) |
virtual void | OnBeforeMessagesHandled () |
virtual void | OnAllMessagesHandled () |
virtual void | OnStarted () |
virtual void | OnStopped () |
Additional Inherited Members | |
Protected Member Functions inherited from Eegeo::NonCopyable | |
NonCopyable (const NonCopyable &)=delete | |
NonCopyable & | operator= (const NonCopyable &)=delete |