|
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 |