ThreadUtils::CObjectQueue< TWhat >

#include <ThreadUtils.h>

Public Member Functions
	CObjectQueue ()
template<typename TSource >
void	Add (const TSource &source)
template<typename TDestination >
void	Get (TDestination &out, abort_callback &abort)
template<typename TDestination >
void	Get_MsgLoop (TDestination &out, abort_callback &abort)

Private Member Functions
template<typename TDestination >
void	_Get (TDestination &out)

Private Attributes
pfc::chain_list_v2_t< TWhat >	m_content
win32_event	m_event
critical_section	m_sync

Detailed Description

template<typename TWhat>
class ThreadUtils::CObjectQueue< TWhat >

Definition at line 133 of file ThreadUtils.h.

Constructor & Destructor Documentation

template<typename TWhat>

ThreadUtils::CObjectQueue< TWhat >::CObjectQueue ( )

inline

Definition at line 135 of file ThreadUtils.h.

{ m_event.create(true,false); }

Member Function Documentation

template<typename TWhat>

template<typename TDestination >

void ThreadUtils::CObjectQueue< TWhat >::_Get ( TDestination &  out )

inlineprivate

Definition at line 153 of file ThreadUtils.h.

                                                                      {
            insync(m_sync);
            pfc::const_iterator<TWhat> iter = m_content.first();
            FB2K_DYNAMIC_ASSERT( iter.is_valid() );
            out = *iter;
            m_content.remove(iter);
            if (m_content.get_count() == 0) m_event.set_state(false);
        }

template<typename TWhat>

template<typename TSource >

void ThreadUtils::CObjectQueue< TWhat >::Add ( const TSource &  source )

inline

Definition at line 137 of file ThreadUtils.h.

                                                                    {
            insync(m_sync);
            m_content.add_item(source);
            if (m_content.get_count() == 1) m_event.set_state(true);
        }

template<typename TWhat>

template<typename TDestination >

void ThreadUtils::CObjectQueue< TWhat >::Get ( TDestination &  out, abort_callback &  abort  )

inline

Definition at line 142 of file ThreadUtils.h.

                                                                                             {
            WaitAbortable(m_event.get(), abort);
            _Get(out);
        }

template<typename TWhat>

template<typename TDestination >

void ThreadUtils::CObjectQueue< TWhat >::Get_MsgLoop ( TDestination &  out, abort_callback &  abort  )

inline

Definition at line 147 of file ThreadUtils.h.

                                                                                                     {
            WaitAbortable_MsgLoop(m_event.get(), abort);
            _Get(out);
        }

Field Documentation

template<typename TWhat>

pfc::chain_list_v2_t<TWhat> ThreadUtils::CObjectQueue< TWhat >::m_content

private

Definition at line 163 of file ThreadUtils.h.

template<typename TWhat>

win32_event ThreadUtils::CObjectQueue< TWhat >::m_event

private

Definition at line 161 of file ThreadUtils.h.

template<typename TWhat>

critical_section ThreadUtils::CObjectQueue< TWhat >::m_sync

private

Definition at line 162 of file ThreadUtils.h.

---

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

• foobar2000/helpers/ThreadUtils.h