closeBuffer() | Bloomberg::quantum::Context< RET > | |
Context class | Bloomberg::quantum::Context< RET > | friend |
Bloomberg::ContextTag typedef | Bloomberg::quantum::IThreadContext< RET > | |
Bloomberg::quantum::ICoroContext::ContextTag typedef | Bloomberg::quantum::ICoroContext< RET > | |
CoroCtx typedef | Bloomberg::quantum::Context< RET > | |
deleter(Context< RET > *p) | Bloomberg::quantum::Context< RET > | static |
Dispatcher class | Bloomberg::quantum::Context< RET > | friend |
end() | Bloomberg::quantum::Context< RET > | |
finally(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
finally(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
forEach(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func) | Bloomberg::quantum::Context< RET > | |
forEach(INPUT_IT first, size_t num, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func) | Bloomberg::quantum::Context< RET > | |
forEach(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func) | Bloomberg::quantum::Context< RET > | |
forEach(INPUT_IT first, size_t num, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func) | Bloomberg::quantum::Context< RET > | |
forEachBatch(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func) | Bloomberg::quantum::Context< RET > | |
forEachBatch(INPUT_IT first, size_t num, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func) | Bloomberg::quantum::Context< RET > | |
forEachBatch(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func) | Bloomberg::quantum::Context< RET > | |
forEachBatch(INPUT_IT first, size_t num, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func) | Bloomberg::quantum::Context< RET > | |
get() | Bloomberg::quantum::Context< RET > | |
get(ICoroSync::Ptr sync) | Bloomberg::quantum::Context< RET > | |
getAt(int num) | Bloomberg::quantum::Context< RET > | |
getAt(int num, ICoroSync::Ptr sync) | Bloomberg::quantum::Context< RET > | |
getCoroQueueIdRangeForAny() const | Bloomberg::quantum::Context< RET > | |
getNumCoroutineThreads() const | Bloomberg::quantum::Context< RET > | |
getNumIoThreads() const | Bloomberg::quantum::Context< RET > | |
getPrev(ICoroSync::Ptr sync) | Bloomberg::quantum::Context< RET > | |
Bloomberg::quantum::ICoroContext::getPrev() | Bloomberg::quantum::ICoroContext< RET > | |
getPrevRef(ICoroSync::Ptr sync) | Bloomberg::quantum::Context< RET > | |
Bloomberg::quantum::ICoroContext::getPrevRef() | Bloomberg::quantum::ICoroContext< RET > | |
getRef() const | Bloomberg::quantum::Context< RET > | |
getRef(ICoroSync::Ptr sync) const | Bloomberg::quantum::Context< RET > | |
getRefAt(int num) const | Bloomberg::quantum::Context< RET > | |
getRefAt(int num, ICoroSync::Ptr sync) const | Bloomberg::quantum::Context< RET > | |
getTask() const final | Bloomberg::quantum::Context< RET > | virtual |
getYieldHandle() final | Bloomberg::quantum::Context< RET > | virtual |
Bloomberg::Impl typedef | Bloomberg::quantum::IThreadContext< RET > | |
Bloomberg::quantum::ICoroContext::Impl typedef | Bloomberg::quantum::ICoroContext< RET > | |
isBlocked() const final | Bloomberg::quantum::Context< RET > | virtual |
isSleeping(bool updateTimer=false) final | Bloomberg::quantum::Context< RET > | virtual |
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::Context< RET > | |
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::Context< RET > | |
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::Context< RET > | |
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::Context< RET > | |
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::Context< RET > | |
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::Context< RET > | |
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::Context< RET > | |
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::Context< RET > | |
onError(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
onError(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
operator delete(void *p) | Bloomberg::quantum::Context< RET > | static |
operator new(size_t size) | Bloomberg::quantum::Context< RET > | static |
post(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
post(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
post(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
post(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
postAsyncIo(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
postAsyncIo(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
postFirst(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
postFirst(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
postFirst(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
postFirst(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
postImpl(int queueId, bool isHighPriority, ITask::Type type, FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
Ptr typedef | Bloomberg::quantum::Context< RET > | |
pull(bool &isBufferClosed) | Bloomberg::quantum::Context< RET > | |
pull(ICoroSync::Ptr sync, bool &isBufferClosed) | Bloomberg::quantum::Context< RET > | |
push(V &&value) | Bloomberg::quantum::Context< RET > | |
push(ICoroSync::Ptr sync, V &&value) | Bloomberg::quantum::Context< RET > | |
set(V &&value) | Bloomberg::quantum::Context< RET > | |
set(ICoroSync::Ptr sync, V &&value) | Bloomberg::quantum::Context< RET > | |
setException(std::exception_ptr ex) final | Bloomberg::quantum::Context< RET > | virtual |
setTask(ITask::Ptr task) final | Bloomberg::quantum::Context< RET > | virtual |
setYieldHandle(Traits::Yield &yield) final | Bloomberg::quantum::Context< RET > | virtual |
signal() final | Bloomberg::quantum::Context< RET > | virtual |
sleep(const std::chrono::milliseconds &timeMs) final | Bloomberg::quantum::Context< RET > | virtual |
sleep(const std::chrono::microseconds &timeUs) final | Bloomberg::quantum::Context< RET > | virtual |
Task class | Bloomberg::quantum::Context< RET > | friend |
terminate() final | Bloomberg::quantum::Context< RET > | virtual |
then(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
then(FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
thenImpl(ITask::Type type, FUNC &&func, ARGS &&... args) | Bloomberg::quantum::Context< RET > | |
ThreadCtx typedef | Bloomberg::quantum::Context< RET > | |
Util | Bloomberg::quantum::Context< RET > | friend |
valid() const final | Bloomberg::quantum::Context< RET > | virtual |
validAt(int num) const final | Bloomberg::quantum::Context< RET > | virtual |
wait() const final | Bloomberg::quantum::Context< RET > | virtual |
wait(ICoroSync::Ptr sync) const final | Bloomberg::quantum::Context< RET > | virtual |
waitAll() const final | Bloomberg::quantum::Context< RET > | virtual |
waitAll(ICoroSync::Ptr sync) const final | Bloomberg::quantum::Context< RET > | virtual |
waitAt(int num) const final | Bloomberg::quantum::Context< RET > | virtual |
waitAt(int num, ICoroSync::Ptr sync) const final | Bloomberg::quantum::Context< RET > | virtual |
waitFor(std::chrono::milliseconds timeMs) const final | Bloomberg::quantum::Context< RET > | virtual |
waitFor(ICoroSync::Ptr sync, std::chrono::milliseconds timeMs) const final | Bloomberg::quantum::Context< RET > | virtual |
waitForAt(int num, std::chrono::milliseconds timeMs) const final | Bloomberg::quantum::Context< RET > | virtual |
waitForAt(int num, ICoroSync::Ptr sync, std::chrono::milliseconds timeMs) const final | Bloomberg::quantum::Context< RET > | virtual |
yield() final | Bloomberg::quantum::Context< RET > | virtual |
~Context() | Bloomberg::quantum::Context< RET > | |
~IContextBase()=default | Bloomberg::quantum::IContextBase | virtual |
~ICoroSync()=default | Bloomberg::quantum::ICoroSync | virtual |
~ITerminate()=default | Bloomberg::quantum::ITerminate | virtual |