Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink > Class Template Reference

#include <MPSCQueue.h>

Public Member Functions
	MPSCQueueIntrusive ()
	~MPSCQueueIntrusive ()
void	Enqueue (T *input)
bool	Dequeue (T *&result)

Private Member Functions
	MPSCQueueIntrusive (MPSCQueueIntrusive const &)=delete
MPSCQueueIntrusive &	operator= (MPSCQueueIntrusive const &)=delete

Private Attributes
std::aligned_storage_t< sizeof(T), alignof(T)>	_dummy
T *	_dummyPtr
std::atomic< T * >	_head
std::atomic< T * >	_tail

Detailed Description

template<typename T, std::atomic< T * > T::* IntrusiveLink>
class Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >

Definition at line 93 of file MPSCQueue.h.

Constructor & Destructor Documentation

MPSCQueueIntrusive() [1/2]

template<typename T , std::atomic< T * > T::* IntrusiveLink>

Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::MPSCQueueIntrusive ( )

inline

Definition at line 96 of file MPSCQueue.h.

References Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::_dummyPtr.

~MPSCQueueIntrusive()

template<typename T , std::atomic< T * > T::* IntrusiveLink>

Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::~MPSCQueueIntrusive ( )

inline

Definition at line 104 of file MPSCQueue.h.

References Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::Dequeue().

MPSCQueueIntrusive() [2/2]

template<typename T , std::atomic< T * > T::* IntrusiveLink>

Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::MPSCQueueIntrusive ( MPSCQueueIntrusive< T, IntrusiveLink > const &  )

privatedelete

Member Function Documentation

Dequeue()

template<typename T , std::atomic< T * > T::* IntrusiveLink>

bool Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::Dequeue ( T *&  result )

inline

Definition at line 118 of file MPSCQueue.h.

References Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::_dummyPtr, Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::_head, Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::_tail, and Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::Enqueue().

Referenced by Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::~MPSCQueueIntrusive().

Enqueue()

template<typename T , std::atomic< T * > T::* IntrusiveLink>

void Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::Enqueue ( T *  input )

inline

Definition at line 111 of file MPSCQueue.h.

References Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::_head.

Referenced by Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::Dequeue().

operator=()

template<typename T , std::atomic< T * > T::* IntrusiveLink>

MPSCQueueIntrusive & Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::operator= ( MPSCQueueIntrusive< T, IntrusiveLink > const &  )

privatedelete

Member Data Documentation

_dummy

template<typename T , std::atomic< T * > T::* IntrusiveLink>

std::aligned_storage_t<sizeof(T), alignof(T)> Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::_dummy

private

Definition at line 155 of file MPSCQueue.h.

_dummyPtr

template<typename T , std::atomic< T * > T::* IntrusiveLink>

T* Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::_dummyPtr

private

Definition at line 156 of file MPSCQueue.h.

Referenced by Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::Dequeue(), and Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::MPSCQueueIntrusive().

_head

template<typename T , std::atomic< T * > T::* IntrusiveLink>

std::atomic<T*> Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::_head

private

Definition at line 157 of file MPSCQueue.h.

Referenced by Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::Dequeue(), and Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::Enqueue().

_tail

template<typename T , std::atomic< T * > T::* IntrusiveLink>

std::atomic<T*> Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::_tail

private

Definition at line 158 of file MPSCQueue.h.

Referenced by Trinity::Impl::MPSCQueueIntrusive< T, IntrusiveLink >::Dequeue().

---

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

• common/Threading/MPSCQueue.h