add(const unsigned long long threadId, const std::vector< TWorker > &tWorkers, const unsigned long long queueInId, const unsigned long long queueOutId) | op::ThreadManager< TDatums, TWorker, TQueue > | |
add(const unsigned long long threadId, const TWorker &tWorker, const unsigned long long queueInId, const unsigned long long queueOutId) | op::ThreadManager< TDatums, TWorker, TQueue > | |
exec() | op::ThreadManager< TDatums, TWorker, TQueue > | |
getIsRunningSharedPtr() | op::ThreadManager< TDatums, TWorker, TQueue > | inline |
isRunning() const | op::ThreadManager< TDatums, TWorker, TQueue > | inline |
reset() | op::ThreadManager< TDatums, TWorker, TQueue > | |
setDefaultMaxSizeQueues(const long long defaultMaxSizeQueues=-1) | op::ThreadManager< TDatums, TWorker, TQueue > | |
start() | op::ThreadManager< TDatums, TWorker, TQueue > | |
stop() | op::ThreadManager< TDatums, TWorker, TQueue > | |
ThreadManager(const ThreadManagerMode threadManagerMode=ThreadManagerMode::Synchronous) | op::ThreadManager< TDatums, TWorker, TQueue > | explicit |
tryEmplace(TDatums &tDatums) | op::ThreadManager< TDatums, TWorker, TQueue > | |
tryPop(TDatums &tDatums) | op::ThreadManager< TDatums, TWorker, TQueue > | |
tryPush(const TDatums &tDatums) | op::ThreadManager< TDatums, TWorker, TQueue > | |
waitAndEmplace(TDatums &tDatums) | op::ThreadManager< TDatums, TWorker, TQueue > | |
waitAndPop(TDatums &tDatums) | op::ThreadManager< TDatums, TWorker, TQueue > | |
waitAndPush(const TDatums &tDatums) | op::ThreadManager< TDatums, TWorker, TQueue > | |
~ThreadManager() | op::ThreadManager< TDatums, TWorker, TQueue > | virtual |