Acquire() | ConcurrentWorkers< WorkerT > | inlineprotected |
callback_thread_ | ConcurrentWorkers< WorkerT > | private |
CallbackJob typedef | ConcurrentWorkers< WorkerT > | protected |
CallbackPtr typedef | Observable< WorkerT::returned_data > | |
CallbackQueue typedef | ConcurrentWorkers< WorkerT > | private |
Callbacks typedef | Observable< WorkerT::returned_data > | protected |
CallbackTN typedef | Callbackable< WorkerT::returned_data > | |
ConcurrentWorkers(const size_t number_of_workers, const size_t maximal_queue_length, worker_context_t *worker_context=NULL) | ConcurrentWorkers< WorkerT > | |
expected_data_t typedef | ConcurrentWorkers< WorkerT > | |
GetNumberOfFailedJobs() const | ConcurrentWorkers< WorkerT > | inline |
GetNumberOfWorkers() const | ConcurrentWorkers< WorkerT > | inline |
Initialize() | ConcurrentWorkers< WorkerT > | |
initialized_ | ConcurrentWorkers< WorkerT > | private |
IsRunning() const | ConcurrentWorkers< WorkerT > | inlineprotected |
JobDone(const returned_data_t &data, const bool success=true) | ConcurrentWorkers< WorkerT > | protected |
JobFailed(const returned_data_t &data) | ConcurrentWorkers< WorkerT > | inline |
JobQueue typedef | ConcurrentWorkers< WorkerT > | private |
jobs_all_done_ | ConcurrentWorkers< WorkerT > | mutableprivate |
jobs_all_done_mutex_ | ConcurrentWorkers< WorkerT > | mutableprivate |
jobs_failed_ | ConcurrentWorkers< WorkerT > | mutableprivate |
jobs_pending_ | ConcurrentWorkers< WorkerT > | mutableprivate |
jobs_processed_ | ConcurrentWorkers< WorkerT > | mutableprivate |
jobs_queue_ | ConcurrentWorkers< WorkerT > | private |
JobSuccessful(const returned_data_t &data) | ConcurrentWorkers< WorkerT > | inline |
MakeCallback(typename BoundCallback< WorkerT::returned_data, DelegateT >::CallbackMethod method, DelegateT *delegate) | Callbackable< WorkerT::returned_data > | inlinestatic |
MakeCallback(typename Callback< WorkerT::returned_data >::CallbackFunction function) | Callbackable< WorkerT::returned_data > | inlinestatic |
MakeClosure(typename BoundClosure< WorkerT::returned_data, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, const ClosureDataT &closure_data) | Callbackable< WorkerT::returned_data > | inlinestatic |
NotifyListeners(const WorkerT::returned_data ¶meter) | Observable< WorkerT::returned_data > | protected |
number_of_workers_ | ConcurrentWorkers< WorkerT > | private |
Observable() | Observable< WorkerT::returned_data > | protected |
RegisterListener(typename BoundClosure< WorkerT::returned_data, DelegateT, ClosureDataT >::CallbackMethod method, DelegateT *delegate, ClosureDataT data) | Observable< WorkerT::returned_data > | |
RegisterListener(typename BoundCallback< WorkerT::returned_data, DelegateT >::CallbackMethod method, DelegateT *delegate) | Observable< WorkerT::returned_data > | |
RegisterListener(typename Callback< WorkerT::returned_data >::CallbackFunction fn) | Observable< WorkerT::returned_data > | |
RegisterListener(CallbackPtr callback_object) | Observable< WorkerT::returned_data > | protected |
ReportStartedWorker() const | ConcurrentWorkers< WorkerT > | protected |
results_queue_ | ConcurrentWorkers< WorkerT > | private |
returned_data_t typedef | ConcurrentWorkers< WorkerT > | |
RunCallbackThread() | ConcurrentWorkers< WorkerT > | |
RunCallbackThreadWrapper(void *run_binding) | ConcurrentWorkers< WorkerT > | protectedstatic |
running_ | ConcurrentWorkers< WorkerT > | private |
RunWorker(void *run_binding) | ConcurrentWorkers< WorkerT > | protectedstatic |
Schedule(const expected_data_t &data) | ConcurrentWorkers< WorkerT > | inline |
Schedule(WorkerJob job) | ConcurrentWorkers< WorkerT > | protected |
ScheduleDeathSentences() | ConcurrentWorkers< WorkerT > | protected |
SpawnWorkers() | ConcurrentWorkers< WorkerT > | protected |
StartRunning() | ConcurrentWorkers< WorkerT > | inlineprotected |
status_mutex_ | ConcurrentWorkers< WorkerT > | mutableprivate |
StopRunning() | ConcurrentWorkers< WorkerT > | inlineprotected |
Terminate() | ConcurrentWorkers< WorkerT > | |
thread_context_ | ConcurrentWorkers< WorkerT > | private |
TruncateJobQueue(const bool forget_pending=false) | ConcurrentWorkers< WorkerT > | protected |
UnregisterListener(CallbackPtr callback_object) | Observable< WorkerT::returned_data > | |
UnregisterListeners() | Observable< WorkerT::returned_data > | |
WaitForEmptyQueue() const | ConcurrentWorkers< WorkerT > | |
WaitForTermination() | ConcurrentWorkers< WorkerT > | |
worker_context_ | ConcurrentWorkers< WorkerT > | private |
worker_context_t typedef | ConcurrentWorkers< WorkerT > | |
worker_started_ | ConcurrentWorkers< WorkerT > | mutableprivate |
worker_threads_ | ConcurrentWorkers< WorkerT > | private |
WorkerJob typedef | ConcurrentWorkers< WorkerT > | protected |
workers_started_ | ConcurrentWorkers< WorkerT > | mutableprivate |
WorkerThreads typedef | ConcurrentWorkers< WorkerT > | protected |
~ConcurrentWorkers() | ConcurrentWorkers< WorkerT > | virtual |
~Observable() | Observable< WorkerT::returned_data > | virtual |