QuantumLibrary
|
Class implementing the dispatching logic unto worker threads. Used for both coroutines and IO tasks. More...
#include <quantum_dispatcher_core.h>
Public Member Functions | |
~DispatcherCore () | |
void | terminate () final |
Terminates the object. More... | |
size_t | size (IQueue::QueueType type, int queueId) const |
bool | empty (IQueue::QueueType type, int queueId) const |
QueueStatistics | stats (IQueue::QueueType type, int queueId) |
void | resetStats () |
void | post (Task::Ptr task) |
void | postAsyncIo (IoTask::Ptr task) |
int | getNumCoroutineThreads () const |
int | getNumIoThreads () const |
const std::pair< int, int > & | getCoroQueueIdRangeForAny () const |
![]() | |
virtual | ~ITerminate ()=default |
Virtual destructor. This function is explicitly left empty. More... | |
Friends | |
class | Dispatcher |
Class implementing the dispatching logic unto worker threads. Used for both coroutines and IO tasks.
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inlinefinalvirtual |
Terminates the object.
Implements Bloomberg::quantum::ITerminate.
|
friend |