pfc::thread

#include <threads.h>

Inheritance diagram for pfc::thread:

Public Member Functions
	thread ()
	~thread ()
int	getPriority ()
bool	isActive () const
	PFC_DECLARE_EXCEPTION (exception_creation, exception,"Could not create thread")
pthread_t	posixThreadHandle ()
void	setPriority (int priority)
void	start ()
void	startWithPriority (int priority)
void	waitTillDone ()
void	winStart (int priority, DWORD *outThreadID)
HANDLE	winThreadHandle ()

Static Public Member Functions
static int	currentPriority ()

Protected Member Functions
virtual void	threadProc ()

Private Member Functions
void	close ()
void	entry ()

Static Private Member Functions
static void	appleStartThreadPrologue ()
static unsigned CALLBACK	g_entry (void *p_instance)
static void *	g_entry (void *arg)

Private Attributes
HANDLE	m_thread
pthread_t	m_thread
bool	m_threadValid

Detailed Description

IMPORTANT: all classes derived from thread must call waitTillDone() in their destructor, to avoid object destruction during a virtual function call!

Definition at line 11 of file threads.h.

Constructor & Destructor Documentation

pfc::thread::thread

(

)

Definition at line 56 of file threads.cpp.

                   : m_thread(INVALID_HANDLE_VALUE)
    {
    }

pfc::thread::~thread ( )

inline

Definition at line 15 of file threads.h.

{PFC_ASSERT(!isActive()); waitTillDone();}

Member Function Documentation

void pfc::thread::appleStartThreadPrologue ( )

staticprivate

Definition at line 28 of file obj-c.mm.

                                          {
        if (![NSThread isMultiThreaded]) [[[NSThread alloc] init] start];
    }

void pfc::thread::close ( )

private

Definition at line 60 of file threads.cpp.

                       {
        if (isActive()) {
            
            int ctxPriority = GetThreadPriority( GetCurrentThread() );
            if (ctxPriority > GetThreadPriority( m_thread ) ) SetThreadPriority( m_thread, ctxPriority );
            
            if (WaitForSingleObject(m_thread,INFINITE) != WAIT_OBJECT_0) crash();
            CloseHandle(m_thread); m_thread = INVALID_HANDLE_VALUE;
        }
    }

int pfc::thread::currentPriority ( )

static

Definition at line 106 of file threads.cpp.

                                {
        return GetThreadPriority( GetCurrentThread() );
    }

void pfc::thread::entry ( )

private

Definition at line 49 of file threads.cpp.

                       {
        try {
            threadProc();
        } catch(...) {}
    }

void * pfc::thread::g_entry ( void *  p_instance )

staticprivate

Definition at line 22 of file obj-c.mm.

                                     {
        @autoreleasepool {
            reinterpret_cast<thread*>(arg)->entry();
        }
        return NULL;
    }

static void* pfc::thread::g_entry ( void *  arg )

staticprivate

int pfc::thread::getPriority

(

)

Definition at line 101 of file threads.cpp.

                            {
        PFC_ASSERT(isActive());
        return GetThreadPriority( m_thread );
    }

bool pfc::thread::isActive

(

)

const

Definition at line 70 of file threads.cpp.

                                {
        return m_thread != INVALID_HANDLE_VALUE;
    }

pfc::thread::PFC_DECLARE_EXCEPTION	(	exception_creation	,
		exception	,
		"Could not create thread"
	)

pthread_t pfc::thread::posixThreadHandle ( )

inline

Definition at line 27 of file threads.h.

{ return m_thread; }

void pfc::thread::setPriority

(

int

priority

)

Definition at line 89 of file threads.cpp.

                                         {
        PFC_ASSERT(isActive());
        SetThreadPriority(m_thread, priority);
    }

void pfc::thread::start

(

)

Definition at line 93 of file threads.cpp.

                       {
        startWithPriority(GetThreadPriority(GetCurrentThread()));
    }

void pfc::thread::startWithPriority

(

int

priority

)

Definition at line 86 of file threads.cpp.

                                               {
        winStart(priority, NULL);
    }

virtual void pfc::thread::threadProc ( )

inlineprotectedvirtual

Reimplemented in CSimpleThread, and CVerySimpleThread.

Definition at line 30 of file threads.h.

{PFC_ASSERT(!"Stub thread entry - should not get here");}

void pfc::thread::waitTillDone ( )

inline

Definition at line 21 of file threads.h.

{close();}

void pfc::thread::winStart	(	int	priority,
		DWORD *	outThreadID
	)

Definition at line 73 of file threads.cpp.

                                                           {
        close();
        HANDLE thread;
#ifdef PFC_WINDOWS_DESKTOP_APP
        thread = (HANDLE)_beginthreadex(NULL, 0, g_entry, reinterpret_cast<void*>(this), CREATE_SUSPENDED, (unsigned int*)outThreadID);
#else
        thread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) g_entry, reinterpret_cast<void*>(this), CREATE_SUSPENDED, outThreadID);
#endif
        if (thread == NULL) throw exception_creation();
        SetThreadPriority(thread, priority);
        ResumeThread(thread);
        m_thread = thread;
    }

HANDLE pfc::thread::winThreadHandle ( )

inline

Definition at line 25 of file threads.h.

{ return m_thread; }

Field Documentation

HANDLE pfc::thread::m_thread

private

Definition at line 41 of file threads.h.

pthread_t pfc::thread::m_thread

private

Definition at line 43 of file threads.h.

bool pfc::thread::m_threadValid

private

Definition at line 44 of file threads.h.

---

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

• pfc/threads.h
• pfc/obj-c.mm
• pfc/threads.cpp