#include <observed_queue.h>
Public Member Functions | |
void | clear () override |
bool | dequeue (T &data, const std::chrono::microseconds &duration) override |
bool | empty () const override |
bool | enqueue (T &&value) override |
bool | enqueue (T &value) override |
size_t | size () const override |
bool | tryEnqueue (T &value, const std::chrono::microseconds &duration) override |
bool | tryEnqueue (T &&value, const std::chrono::microseconds &duration) override |
~ObservedSynchronizedQueue () override=default | |
Public Member Functions inherited from Aws::DataFlow::ObservedQueue< T, Allocator > | |
void | setStatusMonitor (std::shared_ptr< StatusMonitor > status_monitor) override |
~ObservedQueue () override=default | |
Public Member Functions inherited from Aws::DataFlow::Source< T > | |
virtual | ~Source ()=default |
Private Types | |
using | DequeueMutex = std::timed_mutex |
using | OQ = ObservedQueue< T, Allocator > |
Private Attributes | |
DequeueMutex | dequeue_mutex_ |
Additional Inherited Members | |
Protected Member Functions inherited from Aws::DataFlow::ObservedQueue< T, Allocator > | |
void | notifyMonitor (const Status &status) |
Protected Attributes inherited from Aws::DataFlow::ObservedQueue< T, Allocator > | |
std::deque< T, Allocator > | dequeue_ |
std::shared_ptr< StatusMonitor > | status_monitor_ |
Adds basic thread safety to the ObservedQueue.
T | |
Allocator |
Definition at line 179 of file observed_queue.h.
|
private |
Definition at line 271 of file observed_queue.h.
|
private |
Definition at line 269 of file observed_queue.h.
|
overridedefault |
|
inlineoverridevirtual |
Clear the dequeue
Reimplemented from Aws::DataFlow::ObservedQueue< T, Allocator >.
Definition at line 263 of file observed_queue.h.
|
inlineoverridevirtual |
Dequeue data and notify the observer of data unavailable if the queue is empty.
Reimplemented from Aws::DataFlow::ObservedQueue< T, Allocator >.
Definition at line 232 of file observed_queue.h.
|
inlineoverridevirtual |
Reimplemented from Aws::DataFlow::ObservedQueue< T, Allocator >.
Definition at line 247 of file observed_queue.h.
|
inlineoverridevirtual |
Enqueue data and notify the observer of data available.
value | to enqueue |
Reimplemented from Aws::DataFlow::ObservedQueue< T, Allocator >.
Definition at line 188 of file observed_queue.h.
|
inlineoverridevirtual |
Enqueue data and notify the observer of data available.
value | to enqueue |
Reimplemented from Aws::DataFlow::ObservedQueue< T, Allocator >.
Definition at line 198 of file observed_queue.h.
|
inlineoverridevirtual |
Reimplemented from Aws::DataFlow::ObservedQueue< T, Allocator >.
Definition at line 255 of file observed_queue.h.
|
inlineoverridevirtual |
Reimplemented from Aws::DataFlow::ObservedQueue< T, Allocator >.
Definition at line 203 of file observed_queue.h.
|
inlineoverridevirtual |
Reimplemented from Aws::DataFlow::ObservedQueue< T, Allocator >.
Definition at line 215 of file observed_queue.h.
|
mutableprivate |
Definition at line 272 of file observed_queue.h.