123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113 |
- #ifndef Thread_H
- #define Thread_H
- #include "Array.h"
- namespace Framework
- {
- class Thread;
- class Critical;
-
- class Thread
- {
- private:
- pthread_t *threadHandleSys;
- int lockCount;
- protected:
- unsigned long threadId;
- pthread_t threadHandle;
- bool run;
- int ref;
- public:
-
- __declspec( dllexport ) Thread();
-
- __declspec( dllexport ) virtual ~Thread();
-
- __declspec( dllexport ) void start();
- #ifdef WIN32
-
- __declspec( dllexport ) void pause();
-
- __declspec( dllexport ) void fortsetzen();
- #endif
-
- __declspec( dllexport ) void ende();
-
- __declspec( dllexport ) virtual void thread();
-
- __declspec( dllexport ) virtual void threadEnd();
-
-
-
- __declspec( dllexport ) bool isRunning() const;
-
-
- __declspec( dllexport ) int warteAufThread( int zeit );
-
-
- void setSystemHandlePointer( pthread_t *ths );
-
- __declspec( dllexport ) pthread_t getThreadHandle() const;
-
-
- __declspec( dllexport ) Thread *getThis();
-
-
- __declspec( dllexport ) virtual Thread *release();
- private:
- void addCriticalLock();
- void removeCriticalLock();
- friend Critical;
- };
- #ifdef WIN32
-
- __declspec( dllexport ) unsigned long __stdcall threadStart( void *param );
- #else
-
- void *threadStart( void *param );
- #endif
-
- class ThreadRegister
- {
- private:
- Array< Thread* > threads;
- CRITICAL_SECTION cs;
- Array< pthread_t > closedThreads;
- public:
-
- ThreadRegister();
-
- ~ThreadRegister();
-
-
- void add( Thread *t );
-
-
- void remove( Thread *t );
-
-
- bool isThread( Thread *t );
-
-
- Thread *zThread( pthread_t handle );
-
-
- void addClosedThread( pthread_t handle );
-
- void lock();
-
- void unlock();
-
- __declspec( dllexport ) void cleanUpClosedThreads();
- };
- }
- #endif
|