cThread.cpp

// Copyright (c) 2008-2011 Raynaldo (Wildicv) Rivera, Joshua (Dark_Kilauea) Jones, Murat (wolfmanfx) Sari
// This file is part of the "cAudio Engine"
// For conditions of distribution and use, see copyright notice in cAudio.h
 
#include "cThread.h"
#include "cAudioSleep.h"
 
namespace cAudio
{
        cAudioThread::cAudioThread(IThreadWorker* pWorker) : ThreadHandle(0), Worker(pWorker), ThreadID(0), IsInit(false), Loop(true)
        {
        }
 
        cAudioThread::~cAudioThread()
        {
        }
 
        bool cAudioThread::start()
        {
        cAudioMutexBasicLock lock(Mutex);
        
                if(IsInit) 
            return IsInit;
        
        IsInit = true;
        
#ifdef CAUDIO_PLATFORM_WIN
                ThreadHandle = reinterpret_cast<HANDLE>(_beginthreadex(0, 0, threadFunc, this, 0, &ThreadID));
#else
                pthread_create( &ThreadHandle, 0, threadFunc, this );
#endif
        IsInit = ThreadHandle != 0;
                return IsInit;
        }
        void cAudioThread::join()
        {
        cAudioMutexBasicLock lock(Mutex);
                if(IsInit)
                {
                        Loop = false;
#ifdef CAUDIO_PLATFORM_WIN
                        WaitForSingleObject(ThreadHandle, INFINITE);
#else
                        pthread_join(ThreadHandle, NULL);
#endif
                }
        }
        void cAudioThread::shutdown()
        {
        cAudioMutexBasicLock lock(Mutex);
                if(IsInit)
                {
                        IsInit = false;
#ifdef CAUDIO_PLATFORM_WIN
                        _endthread();
#else
                        pthread_exit(0);
#endif                  
                }
        }
        void cAudioThread::updateLoop()
        {
                if(IsInit && Worker)
                {
                        while (Loop)
                        {
                                Worker->run();
                        }
                }
        }
 
        bool cAudioThread::isRunning()
        {
                return Loop && IsInit;
        }
 
#ifdef CAUDIO_PLATFORM_WIN
 
    //
    // Usage: SetThreadName (-1, "MainThread");
    //
    const DWORD MS_VC_EXCEPTION = 0x406D1388;
 
#pragma pack(push,8)
    typedef struct tagTHREADNAME_INFO
    {
        DWORD dwType; // Must be 0x1000.
        LPCSTR szName; // Pointer to name (in user addr space).
        DWORD dwThreadID; // Thread ID (-1=caller thread).
        DWORD dwFlags; // Reserved for future use, must be zero.
    } THREADNAME_INFO;
#pragma pack(pop)
 
    inline void SetThreadName(DWORD dwThreadID, const char* threadName)
    {
        THREADNAME_INFO info;
        info.dwType = 0x1000;
        info.szName = threadName;
        info.dwThreadID = dwThreadID;
        info.dwFlags = 0;
 
        __try
        {
            RaiseException(MS_VC_EXCEPTION, 0, sizeof(info) / sizeof(ULONG_PTR), (ULONG_PTR*)&info);
        }
        __except (EXCEPTION_EXECUTE_HANDLER)
        {
        }
    }
 
        unsigned int __stdcall cAudioThread::threadFunc(void *args)
        {
                cAudioThread* pThread = reinterpret_cast<cAudioThread*>(args);
        SetThreadName(GetCurrentThreadId(), "cAudio");
                pThread->updateLoop();
                return 0;
        }
#else
        void* cAudioThread::threadFunc(void* args)
        {
                cAudioThread* pThread = reinterpret_cast<cAudioThread*>(args);
#if defined(CAUDIO_PLATFORM_MAC) || defined(CAUDIO_PLATFORM_IPHONE)
        pthread_setname_np("cAudio");
#else
        pthread_setname_np(pthread_self(), "cAudio");
#endif
        pThread->updateLoop();
                return 0;
        }
#endif
};