NES::BlockingQueue< T > Class Template Reference

#include <BlockingQueue.hpp>

Public Member Functions
	BlockingQueue ()
	BlockingQueue (uint64_t capacity)
void	setCapacity (uint64_t capacityParam)
uint64_t	getCapacity ()
uint64_t	size ()
bool	empty ()
void	reset ()
void	push (const T &elem)
const T	pop ()
const std::optional< T >	popTimeout (uint64_t timeout_ms)

Constructor & Destructor Documentation

BlockingQueue() [1/2]

template<typename T >

NES::BlockingQueue< T >::BlockingQueue ( )

inline

BlockingQueue() [2/2]

template<typename T >

NES::BlockingQueue< T >::BlockingQueue ( uint64_t  capacity )

inline

Member Function Documentation

empty()

template<typename T >

bool NES::BlockingQueue< T >::empty ( )

inline

getCapacity()

template<typename T >

uint64_t NES::BlockingQueue< T >::getCapacity ( )

inline

pop()

template<typename T >

const T NES::BlockingQueue< T >::pop ( )

inline

popTimeout()

template<typename T >

const std::optional<T> NES::BlockingQueue< T >::popTimeout ( uint64_t  timeout_ms )

inline

References NES::timeout.

push()

template<typename T >

void NES::BlockingQueue< T >::push ( const T &  elem )

inline

References NES_TRACE.

reset()

template<typename T >

void NES::BlockingQueue< T >::reset ( )

inline

References NES_TRACE.

setCapacity()

template<typename T >

void NES::BlockingQueue< T >::setCapacity ( uint64_t  capacityParam )

inline

size()

template<typename T >

uint64_t NES::BlockingQueue< T >::size ( )

inline

---

The documentation for this class was generated from the following file:

• /nebulastream/nes-common/include/Util/BlockingQueue.hpp