Foundation::Core::SPSCQueue< T > Class Template Reference

Atomic, bounded single-producer single-consumer FIFO ring buffer with a fixed maximum size. More...

#include <AtomicQueue.hpp>

Public Member Functions
	SPSCQueue (size_t size, Allocator *alloc)
	Construct the SPSC Queue.
template<typename U >
bool	Push (U &&data)
	Try to push data into the queue.
bool	Pop (T &out)
	Try to pop data from the queue.

Private Attributes
const size_t	mModulo
Vector< T >	mBuffer
Atomic< size_t >	mRead {}
Atomic< size_t >	mWrite {}
size_t	mReadCached {}
size_t	mWriteCached {}

Detailed Description

template<typename T>
class Foundation::Core::SPSCQueue< T >

Atomic, bounded single-producer single-consumer FIFO ring buffer with a fixed maximum size.

Template Parameters

T	Data type, must be default constructible.

Constructor & Destructor Documentation

SPSCQueue()

template<typename T >

Foundation::Core::SPSCQueue< T >::SPSCQueue ( size_t  size, Allocator *  alloc  )

inline

Construct the SPSC Queue.

Parameters

size	Bounded size of the queue. Must be a power of two.
alloc	Allocator to use for internal storage.

Member Function Documentation

Pop()

template<typename T >

bool Foundation::Core::SPSCQueue< T >::Pop ( T &  out )

inline

Try to pop data from the queue.

Note

Caller MUST guarantee there is only one concurrent thread calling pop.

Parameters

out	Reference to receive the popped data. This is only valid if the function returns true. The values are move-constructed from the queue.

Returns

True is successful, false if the queue is empty.

Push()

template<typename T >

template<typename U >

bool Foundation::Core::SPSCQueue< T >::Push ( U &&  data )

inline

Try to push data into the queue.

Note

Caller MUST guarantee there is only one concurrent thread calling push.

Parameters

data	The data to push.

Returns

Whether the push was successful. Returns false if the queue is full.

Member Data Documentation

mBuffer

template<typename T >

Vector<T> Foundation::Core::SPSCQueue< T >::mBuffer

private

mModulo

template<typename T >

const size_t Foundation::Core::SPSCQueue< T >::mModulo

private

mRead

template<typename T >

Atomic<size_t> Foundation::Core::SPSCQueue< T >::mRead {}

private

mReadCached

template<typename T >

size_t Foundation::Core::SPSCQueue< T >::mReadCached {}

private

mWrite

template<typename T >

Atomic<size_t> Foundation::Core::SPSCQueue< T >::mWrite {}

private

mWriteCached

template<typename T >

size_t Foundation::Core::SPSCQueue< T >::mWriteCached {}

private

---

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

• Source/Core/AtomicQueue.hpp