CustomThread.h

// CustomThread.h: interface for the CCustomThread class.
//
//////////////////////////////////////////////////////////////////////
 
#if !defined(AFX_CUSTOMTHREAD_H__717C0FE3_DFA5_4C22_A6FE_56A15B3434C8__INCLUDED_)
#define AFX_CUSTOMTHREAD_H__717C0FE3_DFA5_4C22_A6FE_56A15B3434C8__INCLUDED_
 
#ifdef _MSC_VER
#pragma once
#endif // _MSC_VER
 
#include "XThread.h"
 
BEGIN_MOOTOOLS_NAMESPACE
 
typedef enum _THREAD_STATE_INFO
{
    THREAD_STOP = 0x00, // Thread is finished (set in the created thread)
    THREAD_RUN_STATE_FLAGS = 0x0F,
    THREAD_INIT = 0x02, // Thread is being initialized (set in the thread which create the thread)
    THREAD_RUN = 0x04, // Thread is running (set in the created thread)
    THREAD_PAUSE = 0x08, // Thread as stop
    THREAD_ASK_FOR_CANCEL = 0x100, // Ask the thread to cancel (set in the thread which create the thread)
} THREAD_STATE_INFO;
 
#define THREAD_INIT_STATE(a) (a)
#define GET_THREAD_RUN_STATE(a) (a & THREAD_RUN_STATE_FLAGS)
#define SET_THREAD_RUN_STATE(a, b) ((a & ~THREAD_RUN_STATE_FLAGS) | b)
#define SET_CANCEL_THREAD_FLAG(a) (a | THREAD_ASK_FOR_CANCEL)
#define CLEAR_CANCEL_THREAD_FLAG(a) (a & ~THREAD_ASK_FOR_CANCEL)
#define GET_CANCEL_THREAD_FLAG(a) (a & THREAD_ASK_FOR_CANCEL)
 
class DLL_TOOLSFUNCTION CCustomThread : public CXThread  
{
    DECLARE_DYNAMIC_XOBJECT(CCustomThread)
 
protected:
    bool quit;
    static bool stopThreads;
 
public:
    CCustomThread();
    CCustomThread(XTHREADPROC threadCallback, void* threadData);
    virtual ~CCustomThread();
 
    void SetThreadName(const char *name);
    static void SetThreadName(xThreadID threadID, const char *name);
    static void SetCurrentThreadName(const char *name);
    static xThreadID GetCurrentThreadID();
    static unsigned int GetRunningThreadCount();
    static bool HardThreadsTermination(bool onlyNotCriticalThreads = false); // return true if one thread has been killed, false otherwise
    static void WaitEndOfThreads(bool exitApplication = true);
    static void AskForThreadsEnd(bool resumeThreads);
    static bool ThreadsMustTerminate();
    void StopThread();
    bool MustTerminate();
};
 
END_MOOTOOLS_NAMESPACE
 
#endif // !defined(AFX_CUSTOMTHREAD_H__717C0FE3_DFA5_4C22_A6FE_56A15B3434C8__INCLUDED_)