FIX8::ff_unbounded_queue< T * > Class Template Reference

#include <ff_wrapper.hpp>

Public Types
using	value_type = T
using	reference = T &
	Reference type. More...
using	const_reference = const T &
	Const reference type. More...

Public Member Functions
	ff_unbounded_queue ()
	~ff_unbounded_queue ()
bool	try_push (T *source)
void	push (T *source)
bool	try_pop (T *&target)
bool	pop (T *&target)

Private Attributes
ff::uMPMC_Ptr_Queue	_queue

Detailed Description

template<typename T>
class FIX8::ff_unbounded_queue< T * >

Definition at line 90 of file ff_wrapper.hpp.

Member Typedef Documentation

template<typename T >

using FIX8::ff_unbounded_queue< T * >::const_reference = const T&

Const reference type.

Definition at line 101 of file ff_wrapper.hpp.

template<typename T >

using FIX8::ff_unbounded_queue< T * >::reference = T&

Reference type.

Definition at line 98 of file ff_wrapper.hpp.

template<typename T >

using FIX8::ff_unbounded_queue< T * >::value_type = T

Definition at line 95 of file ff_wrapper.hpp.

Constructor & Destructor Documentation

template<typename T >

FIX8::ff_unbounded_queue< T * >::ff_unbounded_queue ( )

inlineexplicit

Definition at line 103 of file ff_wrapper.hpp.

{ _queue.init(); }

template<typename T >

FIX8::ff_unbounded_queue< T * >::~ff_unbounded_queue ( )

inline

Definition at line 104 of file ff_wrapper.hpp.

{}

Member Function Documentation

template<typename T >

bool FIX8::ff_unbounded_queue< T * >::pop ( T *&  target )

inline

Definition at line 109 of file ff_wrapper.hpp.

References FIX8::hypersleep< h_nanoseconds >().

   {
#if defined FIX8_SLEEP_NO_YIELD
      const unsigned cnt_rnd(3);
      unsigned cnt(0);
#endif
      for(;;)
      {
         if (try_pop(target))
            return true;
#if defined FIX8_SLEEP_NO_YIELD
         if ((++cnt %= cnt_rnd) == 0)
            hypersleep<h_nanoseconds>(FIX8_SLEEP_NO_YIELD);
         else
#endif
            sched_yield();
      }

      return false;
   }

template<typename T >

void FIX8::ff_unbounded_queue< T * >::push ( T *  source )

inline

Definition at line 107 of file ff_wrapper.hpp.

{ try_push(source); }

template<typename T >

bool FIX8::ff_unbounded_queue< T * >::try_pop ( T *&  target )

inline

Definition at line 108 of file ff_wrapper.hpp.

{ return _queue.pop(reinterpret_cast<void**>(&target)); }

template<typename T >

bool FIX8::ff_unbounded_queue< T * >::try_push ( T *  source )

inline

Definition at line 106 of file ff_wrapper.hpp.

{ return _queue.push(source); }

Member Data Documentation

template<typename T >

ff::uMPMC_Ptr_Queue FIX8::ff_unbounded_queue< T * >::_queue

private

Definition at line 92 of file ff_wrapper.hpp.

---

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

• ff_wrapper.hpp