Public Member Functions | |
T * | Front () |
Returns the data at the front of the queue without popping it. | |
std::optional< T > | Pop () |
Pops data from the queue. | |
Public Member Functions inherited from enso::Queue< T, QueueConsumer< T > > | |
Queue (Queue &&other)=default | |
Queue & | operator= (Queue &&other)=default |
Element * | buf_addr () const noexcept |
Returns the address of the internal buffer. | |
size_t | size () const noexcept |
Returns the size of the internal buffer. | |
uint32_t | capacity () const noexcept |
Returns the capacity of the queue. | |
Protected Member Functions | |
QueueConsumer (const std::string &queue_name, size_t size, const std::string &huge_page_prefix) noexcept | |
int | Init (bool join_if_exists) noexcept |
Initializes the Queue object. | |
Protected Member Functions inherited from enso::Queue< T, QueueConsumer< T > > | |
Queue (const std::string &queue_name, size_t size, const std::string &huge_page_prefix) noexcept | |
int | Init (bool join_if_exists) noexcept |
Initializes the Queue object. | |
bool | created_queue () const noexcept |
uint32_t | index_mask () const noexcept |
Additional Inherited Members | |
Static Public Member Functions inherited from enso::Queue< T, QueueConsumer< T > > | |
static std::unique_ptr< QueueConsumer< T > > | Create (const std::string &queue_name, size_t size=0, bool join_if_exists=true, std::string huge_page_prefix="") noexcept |
Factory method to create a Queue object. | |
Static Public Attributes inherited from enso::Queue< T, QueueConsumer< T > > | |
static constexpr size_t | kElementMetaSize |
static constexpr size_t | kElementPadding |
|
inlinenoexcept |
|
inlineexplicitprotectednoexcept |
|
inline |
|
inlineprotectednoexcept |
|
inline |