Skip to main content

chronon::sender::SingleThreadQueueAdapter

More...

#include <MessageQueue.hpp>

Inherits from chronon::sender::IMessageQueue< T >

Public Functions​

Name
virtual std::optional< T >tryPop(uint64_t current_cycle) override
virtual size_tsize() const override
virtual voidsetCapacity(size_t capacity) override
virtual boolpush(T data, uint64_t arrive_cycle) override
virtual std::vector< T >popAll(uint64_t current_cycle) override
virtual std::optional< uint64_t >minArrivalCycle() const override
virtual boolhasReady(uint64_t current_cycle) const override
virtual boolfull() const override
virtual boolempty() const override
virtual voidclear() override
virtual size_tcapacity() const override
virtual size_tavailable() const override
SingleThreadQueueAdapter(size_t capacity =SingleThreadMessageQueue< T >::UNLIMITED_CAPACITY)

Additional inherited members​

Public Functions inherited from chronon::sender::IMessageQueue< T >

Name
virtual~IMessageQueue() =default

Detailed Description​

template <typename T >
class chronon::sender::SingleThreadQueueAdapter;

SingleThreadQueueAdapter - Adapts SingleThreadMessageQueue to IMessageQueue.

Public Functions Documentation​

function tryPop​

inline virtual std::optional< T > tryPop(
    uint64_t current_cycle
) override

Reimplements: chronon::sender::IMessageQueue::tryPop

function size​

inline virtual size_t size() const override

Reimplements: chronon::sender::IMessageQueue::size

function setCapacity​

inline virtual void setCapacity(
    size_t capacity
) override

Reimplements: chronon::sender::IMessageQueue::setCapacity

function push​

inline virtual bool push(
    T data,
    uint64_t arrive_cycle
) override

Reimplements: chronon::sender::IMessageQueue::push

function popAll​

inline virtual std::vector< T > popAll(
    uint64_t current_cycle
) override

Reimplements: chronon::sender::IMessageQueue::popAll

function minArrivalCycle​

inline virtual std::optional< uint64_t > minArrivalCycle() const override

Reimplements: chronon::sender::IMessageQueue::minArrivalCycle

function hasReady​

inline virtual bool hasReady(
    uint64_t current_cycle
) const override

Reimplements: chronon::sender::IMessageQueue::hasReady

function full​

inline virtual bool full() const override

Reimplements: chronon::sender::IMessageQueue::full

function empty​

inline virtual bool empty() const override

Reimplements: chronon::sender::IMessageQueue::empty

function clear​

inline virtual void clear() override

Reimplements: chronon::sender::IMessageQueue::clear

function capacity​

inline virtual size_t capacity() const override

Reimplements: chronon::sender::IMessageQueue::capacity

function available​

inline virtual size_t available() const override

Reimplements: chronon::sender::IMessageQueue::available

function SingleThreadQueueAdapter​

inline explicit SingleThreadQueueAdapter(
    size_t capacity =SingleThreadMessageQueue< T >::UNLIMITED_CAPACITY
)

Updated on 2026-05-26 at 05:42:32 +0000