QuantumLibrary
Bloomberg::quantum::Dispatcher Member List

This is the complete list of members for Bloomberg::quantum::Dispatcher, including all inherited members.

ContextTag typedefBloomberg::quantum::Dispatcher
Dispatcher(int numCoroutineThreads=-1, int numIoThreads=5, bool pinCoroutineThreadsToCores=false)Bloomberg::quantum::Dispatcherinline
Dispatcher(const Configuration &config)Bloomberg::quantum::Dispatcherexplicit
drain(std::chrono::milliseconds timeout=std::chrono::milliseconds::zero())Bloomberg::quantum::Dispatcherinline
empty(IQueue::QueueType type=IQueue::QueueType::All, int queueId=(int) IQueue::QueueId::All) constBloomberg::quantum::Dispatcherinline
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() constBloomberg::quantum::Dispatcherinline
getNumCoroutineThreads() constBloomberg::quantum::Dispatcherinline
getNumIoThreads() constBloomberg::quantum::Dispatcherinline
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::Dispatcherinline
size(IQueue::QueueType type=IQueue::QueueType::All, int queueId=(int) IQueue::QueueId::All) constBloomberg::quantum::Dispatcherinline
stats(IQueue::QueueType type=IQueue::QueueType::All, int queueId=(int) IQueue::QueueId::All)Bloomberg::quantum::Dispatcherinline
terminate() finalBloomberg::quantum::Dispatcherinlinevirtual
~Dispatcher()Bloomberg::quantum::Dispatcher
~ITerminate()=defaultBloomberg::quantum::ITerminatevirtual