QuantumLibrary
|
This is the complete list of members for Bloomberg::quantum::Dispatcher, including all inherited members.
ContextTag typedef | Bloomberg::quantum::Dispatcher | |
Dispatcher(int numCoroutineThreads=-1, int numIoThreads=5, bool pinCoroutineThreadsToCores=false) | Bloomberg::quantum::Dispatcher | inline |
Dispatcher(const Configuration &config) | Bloomberg::quantum::Dispatcher | explicit |
drain(std::chrono::milliseconds timeout=std::chrono::milliseconds::zero()) | Bloomberg::quantum::Dispatcher | inline |
empty(IQueue::QueueType type=IQueue::QueueType::All, int queueId=(int) IQueue::QueueId::All) const | Bloomberg::quantum::Dispatcher | inline |
forEach(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< RET, INPUT_IT > func) | Bloomberg::quantum::Dispatcher | |
forEach(INPUT_IT first, size_t num, Functions::ForEachFunc< RET, INPUT_IT > func) | Bloomberg::quantum::Dispatcher | |
forEachBatch(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< RET, INPUT_IT > func) | Bloomberg::quantum::Dispatcher | |
forEachBatch(INPUT_IT first, size_t num, Functions::ForEachFunc< RET, INPUT_IT > func) | Bloomberg::quantum::Dispatcher | |
getCoroQueueIdRangeForAny() const | Bloomberg::quantum::Dispatcher | inline |
getNumCoroutineThreads() const | Bloomberg::quantum::Dispatcher | inline |
getNumIoThreads() const | Bloomberg::quantum::Dispatcher | inline |
mapReduce(INPUT_IT first, INPUT_IT last, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer) | Bloomberg::quantum::Dispatcher | |
mapReduce(INPUT_IT first, size_t num, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer) | Bloomberg::quantum::Dispatcher | |
mapReduceBatch(INPUT_IT first, INPUT_IT last, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer) | Bloomberg::quantum::Dispatcher | |
mapReduceBatch(INPUT_IT first, size_t num, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer) | Bloomberg::quantum::Dispatcher | |
post(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Dispatcher | |
post(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Dispatcher | |
postAsyncIo(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Dispatcher | |
postAsyncIo(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Dispatcher | |
postFirst(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Dispatcher | |
postFirst(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Dispatcher | |
resetStats() | Bloomberg::quantum::Dispatcher | inline |
size(IQueue::QueueType type=IQueue::QueueType::All, int queueId=(int) IQueue::QueueId::All) const | Bloomberg::quantum::Dispatcher | inline |
stats(IQueue::QueueType type=IQueue::QueueType::All, int queueId=(int) IQueue::QueueId::All) | Bloomberg::quantum::Dispatcher | inline |
terminate() final | Bloomberg::quantum::Dispatcher | inlinevirtual |
~Dispatcher() | Bloomberg::quantum::Dispatcher | |
~ITerminate()=default | Bloomberg::quantum::ITerminate | virtual |