16 #ifndef BLOOMBERG_QUANTUM_QUEUE_STATISTICS_H 17 #define BLOOMBERG_QUANTUM_QUEUE_STATISTICS_H 19 #include <quantum/interface/quantum_iqueue_statistics.h> 73 void print(
std::ostream& out) const final;
83 size_t _sharedQueueErrorCount;
84 size_t _completedCount;
85 size_t _sharedQueueCompletedCount;
87 size_t _highPriorityCount;
92 #include <quantum/impl/quantum_queue_statistics_impl.h> 94 #endif //BLOOMBERG_QUANTUM_QUEUE_STATISTICS_H Definition: quantum_buffer_impl.h:22
size_t sharedQueueCompletedCount() const final
Count of all IO tasks which were dequeued from the shared queue and completed successfully.
Definition: quantum_queue_statistics_impl.h:98
QueueStatistics()
Definition: quantum_queue_statistics_impl.h:26
void reset() final
Reset all the counters to 0.
Definition: quantum_queue_statistics_impl.h:32
void incHighPriorityCount() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:128
size_t postedCount() const final
Count of all coroutine and IO tasks which were posted on this queue.
Definition: quantum_queue_statistics_impl.h:110
Definition: quantum_stl_impl.h:23
void incSharedQueueErrorCount() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:80
friend class IOQueue
Definition: quantum_queue_statistics.h:33
void incPostedCount() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:116
Provides various counters related to queues and task execution.
Definition: quantum_queue_statistics.h:30
size_t errorCount() const final
Count of all coroutine and IO task execution errors on this queue.
Definition: quantum_queue_statistics_impl.h:62
Thread queue for running coroutines.
Definition: quantum_task_queue.h:45
void incSharedQueueCompletedCount() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:104
size_t sharedQueueErrorCount() const final
Count of all IO tasks which were dequeued from the shared queue and failed.
Definition: quantum_queue_statistics_impl.h:74
void incCompletedCount() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:92
size_t highPriorityCount() const final
Count of all coroutine and IO tasks which were posted on this queue at higher priority.
Definition: quantum_queue_statistics_impl.h:122
void incErrorCount() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:68
size_t completedCount() const final
Count of all coroutine and IO tasks which completed successfully.
Definition: quantum_queue_statistics_impl.h:86
Interface to access and manipulate a QueueStatistics object.
Definition: quantum_iqueue_statistics.h:29
size_t numElements() const final
Gets the current size of the queue.
Definition: quantum_queue_statistics_impl.h:44
void incNumElements() final
Increment this counter.
Definition: quantum_queue_statistics_impl.h:50
void print(std::ostream &out) const final
Print to std::cout the value of all internal counters.
Definition: quantum_queue_statistics_impl.h:134
void decNumElements() final
Decrement this counter.
Definition: quantum_queue_statistics_impl.h:56