ThreadUtils::CSingleThreadWrapper< TBase, processMsgs >

#include <ThreadUtils.h>

Inheritance diagram for ThreadUtils::CSingleThreadWrapper< TBase, processMsgs >:

Data Structures
class	command

Protected Types
typedef pfc::rcptr_t< command >	command_ptr

Protected Member Functions
	CSingleThreadWrapper ()
	~CSingleThreadWrapper ()
void	invokeCommand (command_ptr cmd, abort_callback &abort)
Protected Member Functions inherited from CVerySimpleThread
	CVerySimpleThread ()
bool	IsThreadActive () const
void	StartThread (int priority)
void	StartThread ()
void	WaitTillThreadDone ()

Private Types
enum	status {   success, fail, fail_io, fail_io_data,   fail_abort }

Private Member Functions
void	ThreadProc ()

Private Attributes
CObjectQueue< command_ptr >	m_commands
win32_event	m_completionEvent
abort_callback_impl	m_threadAbort

Detailed Description

template<typename TBase, bool processMsgs = false>
class ThreadUtils::CSingleThreadWrapper< TBase, processMsgs >

Definition at line 168 of file ThreadUtils.h.

Member Typedef Documentation

template<typename TBase , bool processMsgs = false>

typedef pfc::rcptr_t<command> ThreadUtils::CSingleThreadWrapper< TBase, processMsgs >::command_ptr

protected

Definition at line 221 of file ThreadUtils.h.

Member Enumeration Documentation

template<typename TBase , bool processMsgs = false>

enum ThreadUtils::CSingleThreadWrapper::status

private

Enumerator
success
fail
fail_io
fail_io_data
fail_abort

Definition at line 170 of file ThreadUtils.h.

                    {
            success,
            fail,
            fail_io,
            fail_io_data,
            fail_abort,
        };

Constructor & Destructor Documentation

template<typename TBase , bool processMsgs = false>

ThreadUtils::CSingleThreadWrapper< TBase, processMsgs >::CSingleThreadWrapper ( )

inlineprotected

Definition at line 223 of file ThreadUtils.h.

                               {
            m_completionEvent.create(true,false);
            this->StartThread();
            //start();
        }

template<typename TBase , bool processMsgs = false>

ThreadUtils::CSingleThreadWrapper< TBase, processMsgs >::~CSingleThreadWrapper ( )

inlineprotected

Definition at line 229 of file ThreadUtils.h.

                                {
            m_threadAbort.abort();
            this->WaitTillThreadDone();
        }

Member Function Documentation

template<typename TBase , bool processMsgs = false>

void ThreadUtils::CSingleThreadWrapper< TBase, processMsgs >::invokeCommand ( command_ptr  cmd, abort_callback &  abort  )

inlineprotected

Definition at line 234 of file ThreadUtils.h.

                                                                    {
            abort.check();
            m_completionEvent.set_state(false);
            pfc::vartoggle_t<abort_callback*> abortToggle(cmd->m_abort, &abort);
            pfc::vartoggle_t<HANDLE> eventToggle(cmd->m_completionEvent, m_completionEvent.get() );
            m_commands.Add(cmd);
            m_completionEvent.wait_for(-1);
            //WaitAbortable(m_completionEvent.get(), abort);
            cmd->rethrow();
        }

template<typename TBase , bool processMsgs = false>

void ThreadUtils::CSingleThreadWrapper< TBase, processMsgs >::ThreadProc ( )

inlineprivatevirtual

Implements CVerySimpleThread.

Definition at line 246 of file ThreadUtils.h.

                          {
            TRACK_CALL_TEXT("CSingleThreadWrapper entry");
            try {
                TBase instance;
                for(;;) {
                    command_ptr cmd;
                    if (processMsgs) m_commands.Get_MsgLoop(cmd, m_threadAbort);
                    else m_commands.Get(cmd, m_threadAbort);
                    cmd->execute(instance);
                }
            } catch(...) {}
            if (processMsgs) ProcessPendingMessages();
        }

Field Documentation

template<typename TBase , bool processMsgs = false>

CObjectQueue<command_ptr> ThreadUtils::CSingleThreadWrapper< TBase, processMsgs >::m_commands

private

Definition at line 260 of file ThreadUtils.h.

template<typename TBase , bool processMsgs = false>

win32_event ThreadUtils::CSingleThreadWrapper< TBase, processMsgs >::m_completionEvent

private

Definition at line 259 of file ThreadUtils.h.

template<typename TBase , bool processMsgs = false>

abort_callback_impl ThreadUtils::CSingleThreadWrapper< TBase, processMsgs >::m_threadAbort

private

Definition at line 261 of file ThreadUtils.h.

---

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

• foobar2000/helpers/ThreadUtils.h