D:/Zythum/DinoKod/Common/Thread.cpp

//---------------------------------------------------------------------------------------------
//      This file is a part of "DinoKod".
//      Copyright © 2003 Dino Productions. All Rights Reserved.
//      
//      File                    : Thread.cpp
//      Author                  : Sebastien LEIX        sebastien.leix@wanadoo.fr
//      Date                    : 17/05/2003
//      Modification    :
//
//---------------------------------------------------------------------------------------------
#include "Common/Assert.h"
#include "Common/Thread.h"

//---------------------------------------------------------------------------------------------
KThread::KThread()
{
        m_hThread               = NULL;
        m_hStopEvent    = NULL;
}

//---------------------------------------------------------------------------------------------
bool KThread::IsThreadRunning()
{
        return ( WaitForSingleObject( m_hStopEvent, 0 ) != WAIT_OBJECT_0 );
}

//---------------------------------------------------------------------------------------------
DWORD WINAPI KThread::StaticThreadProc( LPVOID lpParam )
{
        return ((KThread*)lpParam)->ThreadProc();
}

//---------------------------------------------------------------------------------------------
bool KThread::StartThread()
{
        DWORD   ThreadId;

        if( m_hThread )
                StopThread();

        KASSERT( !m_hThread );
        
        // Creation de l'evenement d'arret
        m_hStopEvent = CreateEvent( NULL, FALSE, FALSE, NULL );
        if( !m_hStopEvent )
                return false;

        // Creation du thread
        m_hThread = CreateThread( NULL, 0, StaticThreadProc, this, 0, &ThreadId );
        if( !m_hThread )
        {
                CloseHandle( m_hStopEvent );
                return false;
        }

        return true;
}

//---------------------------------------------------------------------------------------------
bool KThread::StopThread()
{
        // Demande l'arrete du thread
        SetEvent( m_hStopEvent );

        // Attend la fin du thread
        WaitForSingleObject( m_hThread, INFINITE );

        CloseHandle( m_hThread );
        CloseHandle( m_hStopEvent );

        m_hThread               = NULL;
        m_hStopEvent    = NULL;

        return true;
}

//---------------------------------------------------------------------------------------------
void KThread::SetPriority( KTHREADPRIORITY Priority )
{
        int     ThreadPriority = KCTP_NORMAL;

        switch( Priority )
        {
        case KCTP_ABOVE_NORMAL:         ThreadPriority = THREAD_PRIORITY_ABOVE_NORMAL;
        case KCTP_BELOW_NORMAL:         ThreadPriority = THREAD_PRIORITY_BELOW_NORMAL;
        case KCTP_HIGHEST:                      ThreadPriority = THREAD_PRIORITY_HIGHEST;
        case KCTP_IDLE:                         ThreadPriority = THREAD_PRIORITY_IDLE;
        case KCTP_LOWEST:                       ThreadPriority = THREAD_PRIORITY_LOWEST;
        case KCTP_NORMAL:                       ThreadPriority = THREAD_PRIORITY_NORMAL;
        case KCTP_TIME_CRITICAL:        ThreadPriority = THREAD_PRIORITY_TIME_CRITICAL;
        }

        SetThreadPriority( m_hThread, ThreadPriority );
}

---