Thread Class Reference
[Threading]

Thread base class. More...

#include <Thread.h>

Inheritance diagram for Thread:

[legend]

Collaboration diagram for Thread:

[legend]

List of all members.

Public Member Functions
	Thread (bool release=true)
virtual	~Thread ()
virtual void	Run ()=0
pthread_t	GetThread ()
bool	IsRunning ()
void	SetRunning (bool x)
bool	IsReleased ()
void	SetRelease (bool x)
bool	DeleteOnExit ()
void	SetDeleteOnExit (bool x=true)
bool	IsDestructor ()
void	Start ()
void	Stop ()
void	Wait ()
Static Public Member Functions
static threadfunc_t STDPREFIX	StartThread (threadparam_t)
Protected Attributes
pthread_t	m_thread
pthread_attr_t	m_attr
Private Member Functions
	Thread (const Thread &)
Thread &	operator= (const Thread &)
Private Attributes
Semaphore	m_sem
bool	m_running
bool	m_release
bool	m_b_delete_on_exit
bool	m_b_destructor

---

Detailed Description

Thread base class.

The Thread class is used by the resolver (ResolvServer) and running a detached socket (SocketThread). When you know some processing will take a long time and will freeze up a socket, there is always the possibility to call Detach() on that socket before starting the processing. When the OnDetached() callback is later called the processing can continue, now in its own thread.

Definition at line 68 of file Thread.h.

---

Constructor & Destructor Documentation

Thread::Thread

(

bool

release = true

)

Definition at line 49 of file Thread.cpp.

References m_attr, m_release, m_sem, m_thread, Semaphore::Post(), SetRunning(), and StartThread().

:m_thread(0)
,m_running(true)
,m_release(false)
,m_b_delete_on_exit(false)
,m_b_destructor(false)
{
#ifdef _WIN32
//      m_thread = ::CreateThread(NULL, 0, StartThread, this, 0, &m_dwThreadId);
        m_thread = (HANDLE)_beginthreadex(NULL, 0, &StartThread, this, 0, &m_dwThreadId);
#else
        pthread_attr_init(&m_attr);
        pthread_attr_setdetachstate(&m_attr,PTHREAD_CREATE_DETACHED);
        if (pthread_create(&m_thread,&m_attr, StartThread,this) == -1)
        {
                perror("Thread: create failed");
                SetRunning(false);
        }
#endif
        m_release = release;
        if (release)
                m_sem.Post();
}

Thread::~Thread

(

)

[virtual]

Definition at line 74 of file Thread.cpp.

References m_attr, m_b_destructor, m_running, m_thread, SetRelease(), SetRunning(), and Utility::Sleep().

{
        m_b_destructor = true;
        if (m_running)
        {
                SetRelease(true);
                SetRunning(false);
                /*
                        Sleep one second to give thread class Run method enough time to
                        release from run loop
                */
                Utility::Sleep(1000);
        }
#ifdef _WIN32
        if (m_thread)
                ::CloseHandle(m_thread);
#else
        pthread_attr_destroy(&m_attr);
#endif
}

Thread::Thread

(

const Thread &

)

[inline, private]

Definition at line 114 of file Thread.h.

{}

---

Member Function Documentation

threadfunc_t STDPREFIX Thread::StartThread

(

threadparam_t

zz

)

[static]

Definition at line 96 of file Thread.cpp.

References DeleteOnExit(), IsDestructor(), m_running, Run(), SetRunning(), Utility::Sleep(), and Wait().

Referenced by Thread().

{
        /*
                Sleep here to wait for derived thread class constructor to setup
                vtable... hurts just looking at it
        */
        Utility::Sleep(5);

        Thread *p = (Thread *)zz;

        p -> Wait();
        if (p -> m_running)
        {
                p -> Run();
        }
        p -> SetRunning(false); // if return
        if (p -> DeleteOnExit() && !p -> IsDestructor())
        {
                delete p;
        }
#ifdef _WIN32
        _endthreadex(0);
#endif
        return (threadfunc_t)NULL;
}

virtual void Thread::Run

(

)

[pure virtual]

Implemented in ResolvServer, SocketHandlerThread, and SocketThread.

Referenced by StartThread().

pthread_t Thread::GetThread

(

)

[inline]

Definition at line 82 of file Thread.h.

{ return m_thread; }

bool Thread::IsRunning

(

)

Definition at line 123 of file Thread.cpp.

References m_running.

Referenced by SocketThread::Run(), SocketHandlerThread::Run(), ResolvServer::Run(), and SocketThread::~SocketThread().

{
        return m_running;
}

void Thread::SetRunning

(

bool

x

)

Definition at line 129 of file Thread.cpp.

References m_running.

Referenced by ResolvServer::Run(), StartThread(), Thread(), SocketThread::~SocketThread(), and ~Thread().

{
        m_running = x;
}

bool Thread::IsReleased

(

)

Definition at line 135 of file Thread.cpp.

References m_release.

{
        return m_release;
}

void Thread::SetRelease

(

bool

x

)

Definition at line 141 of file Thread.cpp.

References m_release, m_sem, and Semaphore::Post().

Referenced by SocketThread::~SocketThread(), and ~Thread().

{
        m_release = x;
        if (x)
                m_sem.Post();
}

bool Thread::DeleteOnExit

(

)

Definition at line 149 of file Thread.cpp.

References m_b_delete_on_exit.

Referenced by StartThread().

{
        return m_b_delete_on_exit;
}

void Thread::SetDeleteOnExit

(

bool

x = true

)

Definition at line 155 of file Thread.cpp.

References m_b_delete_on_exit.

Referenced by SocketThread::Run().

{
        m_b_delete_on_exit = x;
}

bool Thread::IsDestructor

(

)

Definition at line 161 of file Thread.cpp.

References m_b_destructor.

Referenced by StartThread().

{
        return m_b_destructor;
}

void Thread::Start

(

)

[inline]

Definition at line 93 of file Thread.h.

                     {
                SetRelease(true);
        }

void Thread::Stop

(

)

[inline]

Definition at line 97 of file Thread.h.

                    {
                Start();
                SetRunning(false);
        }

void Thread::Wait

(

)

Reimplemented in SocketHandlerThread.

Definition at line 167 of file Thread.cpp.

References m_sem, and Semaphore::Wait().

Referenced by StartThread().

{
        m_sem.Wait();
}

Thread& Thread::operator=

(

const Thread &

)

[inline, private]

Definition at line 115 of file Thread.h.

{ return *this; }

---

Member Data Documentation

pthread_t Thread::m_thread [protected]

Definition at line 109 of file Thread.h.

Referenced by Thread(), and ~Thread().

pthread_attr_t Thread::m_attr [protected]

Definition at line 110 of file Thread.h.

Referenced by Thread(), and ~Thread().

Semaphore Thread::m_sem [private]

Reimplemented in SocketHandlerThread.

Definition at line 116 of file Thread.h.

Referenced by SetRelease(), Thread(), and Wait().

bool Thread::m_running [private]

Definition at line 117 of file Thread.h.

Referenced by IsRunning(), SetRunning(), StartThread(), and ~Thread().

bool Thread::m_release [private]

Definition at line 118 of file Thread.h.

Referenced by IsReleased(), SetRelease(), and Thread().

bool Thread::m_b_delete_on_exit [private]

Definition at line 119 of file Thread.h.

Referenced by DeleteOnExit(), and SetDeleteOnExit().

bool Thread::m_b_destructor [private]

Definition at line 120 of file Thread.h.

Referenced by IsDestructor(), and ~Thread().

---

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

• Thread.h
• Thread.cpp