_acceptPush | marlinmt::concurrency::ThreadPool< IN, OUT > | private |
_conditionVariable | marlinmt::concurrency::ThreadPool< IN, OUT > | private |
_isDone | marlinmt::concurrency::ThreadPool< IN, OUT > | private |
_isRunning | marlinmt::concurrency::ThreadPool< IN, OUT > | private |
_isStop | marlinmt::concurrency::ThreadPool< IN, OUT > | private |
_mutex | marlinmt::concurrency::ThreadPool< IN, OUT > | private |
_pool | marlinmt::concurrency::ThreadPool< IN, OUT > | private |
_queue | marlinmt::concurrency::ThreadPool< IN, OUT > | private |
acceptPush() const | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
active() const | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
addWorker(Args &&...args) | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
clearQueue() | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
freeSlots() const | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
Future typedef | marlinmt::concurrency::ThreadPool< IN, OUT > | |
isQueueEmpty() const | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
nRunning() const | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
nWaiting() const | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
operator=(const ThreadPool &)=delete | marlinmt::concurrency::ThreadPool< IN, OUT > | |
operator=(ThreadPool &&)=delete | marlinmt::concurrency::ThreadPool< IN, OUT > | |
PoolType typedef | marlinmt::concurrency::ThreadPool< IN, OUT > | |
Promise typedef | marlinmt::concurrency::ThreadPool< IN, OUT > | |
push(PushPolicy policy, IN &&input) | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
PushPolicy enum name | marlinmt::concurrency::ThreadPool< IN, OUT > | |
PushResult typedef | marlinmt::concurrency::ThreadPool< IN, OUT > | |
QueueType typedef | marlinmt::concurrency::ThreadPool< IN, OUT > | |
setAcceptPush(bool accept) | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
setMaxQueueSize(std::size_t maxQueueSize) | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
size() const | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
start() | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
stop(bool clear=true) | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |
ThreadPool()=default | marlinmt::concurrency::ThreadPool< IN, OUT > | |
ThreadPool(const ThreadPool &)=delete | marlinmt::concurrency::ThreadPool< IN, OUT > | |
ThreadPool(ThreadPool &&)=delete | marlinmt::concurrency::ThreadPool< IN, OUT > | |
Worker< IN, OUT > class | marlinmt::concurrency::ThreadPool< IN, OUT > | friend |
~ThreadPool() | marlinmt::concurrency::ThreadPool< IN, OUT > | inline |