C:/Active/libraries/cxutils/2.0/include/cxutils/thread.h
Go to the documentation of this file.
00001 00002 00003 00004 00005 00006 00007 00008 00009 00010 00011 00012 00013 00014 00015 00016 00017 00018 00019 00020 00021 00022 00023 00024 00025 00026 00027 00028 00029 00030 00031 00032 00033 00034 00035 00036 00037 00038 00039 00040 #ifndef __CXUTILS_THREAD_H 00041 #define __CXUTILS_THREAD_H 00042 00043 #ifdef WIN32 00044 00045 #else 00046 #include <stdlib.h> 00047 #include <unistd.h> 00048 #include <signal.h> 00049 #include <pthread.h> 00050 #endif 00051 00052 #include <map> 00053 #include "cxbase.h" 00054 #include "mutex.h" 00055 00062 #ifndef INFINITE 00063 # define INFINITE 0xFFFFFFFF 00064 #endif 00065 00066 namespace CxUtils 00067 { 00084 class CX_UTILS_DLL Thread 00085 { 00086 public: 00087 #ifdef WIN32 00088 typedef unsigned long ID; 00089 #else 00090 typedef pthread_t ID; 00091 #endif 00092 00093 00094 00095 00096 00097 00098 00099 class CX_UTILS_DLL Manager 00100 { 00101 public: 00102 Manager(); 00103 ~Manager(); 00104 bool CreateThread(const std::string& name, void (*func)(void* ), void* args, const int priority = 0); 00105 void StopThread(const std::string& name, const int ms = 500); 00106 void StopAllThreads(); 00107 bool IsThreadActive(const std::string& name) const; 00108 bool QuitThreadFlag(const std::string& name) const; 00109 unsigned int GetNumThreads() const { Mutex::ScopedLock lock(&mMutex); return (unsigned int)mThreads.size(); } 00110 private: 00111 static unsigned int mManagerCount; 00112 Mutex mMutex; 00113 std::map<std::string, Thread*> mThreads; 00114 }; 00115 Thread(); 00116 Thread(const std::string& name); 00117 virtual ~Thread(); 00118 int CreateThread(); 00119 int CreateThread(void (*func)(void* ), 00120 void* args); 00121 int StopThread(const int ms = 500); 00122 int SetThreadPriority(const int priority); 00123 int KillThread(); 00124 bool QuitThreadFlag() const; 00125 bool IsThreadActive() const; 00126 void SetThreadName(const std::string& name); 00127 static Thread::ID GetCurrentThreadID(); 00128 std::string GetThreadName() const; 00129 Thread::ID GetThreadID() const; 00130 protected: 00131 virtual void Execute(); 00132 private: 00133 volatile bool mActive; 00134 volatile bool mQuitThreadFlag; 00135 00136 void InitializeThread(); 00137 void (*mThreadFunc)(void*); 00138 void* mThreadArgs; 00139 std::string mThreadName; 00140 Mutex mFuncCbMutex; 00141 #ifdef WIN32 00142 static unsigned int mThreadNum; 00143 void* mThread; 00144 static unsigned long __stdcall CxThreadProc(void* arg); 00145 #else 00146 static void* CxThreadProc(void* arg); 00147 #endif 00148 ID mThreadId; 00149 }; 00150 } 00151 00152 #endif 00153 00154 /* End of File */
