KSG-Framework/Thread.h

#ifndef Thread_H
#define Thread_H

#include "Array.h"

namespace Framework
{
    class Thread;
    class Critical;

    //! Ein neuer Thread wie die Thread Klasse aus Java
    class Thread
    {
    private:
        pthread_t *threadHandleSys;
        int lockCount;
    protected:
        unsigned long threadId;
        pthread_t threadHandle;
        bool run;
        int ref;

    public:
        //! Konstruktor 
        DLLEXPORT Thread();
        //! Destruktor 
        DLLEXPORT virtual ~Thread();
        //! Startet den neuen Thread 
        DLLEXPORT void start();
#ifdef WIN32
        //! Pausiert den Thread (Nur für Windows)
        DLLEXPORT void pause();
        //! Setzt den Thread Fort (Nur für Windows)
        DLLEXPORT void fortsetzen();
#endif
        //! Beendet den Thread
        DLLEXPORT void ende();
        //! Diese Funktion wird von dem neuen Thread ausgeführt.
        DLLEXPORT virtual void thread();
        //! Diese Funktion wird eufgerufen, nachdem die thread Funktion zuende ist
        DLLEXPORT virtual void threadEnd();
        //! prüft, ob der Thrad aktiv ist
        //! return: true, falls der Thread läuft. 
        //!         false, wenn der Thread beendet, pausiert oder noch nicht gestartet wurde.
        DLLEXPORT bool isRunning() const;
        //! wartet zeit lang auf den Thread
        //! \param zeit Die Zeit, die auf den Thread gewartet werden soll. 1000 = 1 Sekunde
        DLLEXPORT int warteAufThread( int zeit );
        //! Legt einen Frameworkpointer auf ein Threadhandle fest, der auf 0 gesetzt wird, falls die Ressourcen des Threads bereits follstänfig aufgeräumt wurden
        //! \param ths Ein Zeiger auf ein Threadhandle, das verändert werden soll
        void setSystemHandlePointer( pthread_t *ths );
        //! Gibt ein Handle auf den Thread zurück
        DLLEXPORT pthread_t getThreadHandle() const;
        //! Erhöht den Reference Counting Zähler.
        //! \return this.
        DLLEXPORT Thread *getThis();
        //! Verringert den Reference Counting Zähler. Wenn der Zähler 0 erreicht, wird das Zeichnung automatisch gelöscht.
        //! \return 0.
        DLLEXPORT virtual Thread *release();

    private:
        void addCriticalLock();
        void removeCriticalLock();

    friend Critical;
    };

#ifdef WIN32
    //! Diese Funktion wird fon der Thread Klasse benutzt um einen thread zu starten
    DLLEXPORT unsigned long __stdcall threadStart( void *param );
#else
    //! Diese Funktion wird fon der Thread Klasse benutzt um einen thread zu starten
    void *threadStart( void *param ); //! startet thread
#endif

    //! Eine Klasse, die alle aktuell laufenden Thread Objekte speichert
    class ThreadRegister
    {
    private:
        Array< Thread* > threads;
        CRITICAL_SECTION cs;
        Array< pthread_t > closedThreads;

    public:
        //! Konstruktor
        ThreadRegister();
        //! Destruktor
        ~ThreadRegister();
        //! Fügt einen neuen Thread hinzu
        //! \param t Der Thread, der hinzugefügt werden soll
        void add( Thread *t );
        //! Entfernt einen neuen Thread
        //! \param t Der Thread, der entfernt werden soll
        void remove( Thread *t );
        //! Überprüft, ob ein Zeiger auf ein gültiges Thread Objekt zeigt, oder ob es schon gelöscht wurde
        //! \param t Der Zeiger, der geprüft werden soll
        bool isThread( Thread *t );
        //! Sucht nach einem bestimmten Thread und gibt das zugehörige Objekt zurück
        //! handle: Ein handle zu dem gesuchten Thread
        Thread *zThread( pthread_t handle );
        //! Setzt Wird automatisch aufgerufen, wenn ein Thread beendet wird. Die Reccourcen werden daraufhin in cleanUpClosedThreads freigegeben.
        //! \param handle Das Handle des Threads
        void addClosedThread( pthread_t handle );
        //! sperrt das register
        void lock();
        //! entsperrt das register
        void unlock();
        //! Löscht die bereits beendetetn Threads und gibt ihre Reccourcen wieder frei
        DLLEXPORT void cleanUpClosedThreads();
    };
}

#endif