EuEndlessPThread.h

Go to the documentation of this file.

#ifndef INC_EUENDLESSPTHREAD_H
#define INC_EUENDLESSPTHREAD_H
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
#include "EuAPThread.h"
#include <semaphore.h>
//-----------------------------------------------------------------------------
class __euthread_export_dll EuEndlessPThread : public EuAPThread
{
  public:
    //============== local enums
    //-------------------------------------------------------------------------
    enum EuPTHREAD_ORDER
    {
      EuPTHREAD_WORK,
      EuPTHREAD_TAKE_A_BREAK,
      EuPTHREAD_END
    };
    //-------------------------------------------------------------------------
 
  protected:
    //============== Attribute
    //-------------------------------------------------------------------------
    EuPTHREAD_ORDER m_eThreadOrder;
    //-------------------------------------------------------------------------
    pthread_mutex_t m_ExclusiveAccessMutex;
    //-------------------------------------------------------------------------
    pthread_cond_t m_BreakCond;
    //-------------------------------------------------------------------------
    sem_t m_Semaphore;
    //-------------------------------------------------------------------------
    int m_iBreakCounter;
    //-------------------------------------------------------------------------
    bool m_bInExluzivAccess;
    //-------------------------------------------------------------------------
 
  public:
    //============== De- & Konstruktoren
    //-------------------------------------------------------------------------
    EuEndlessPThread();
    //-------------------------------------------------------------------------
    virtual ~EuEndlessPThread();
    //-------------------------------------------------------------------------
 
  private:
    //============== Copy-Konstruktor
    //-------------------------------------------------------------------------
    EuEndlessPThread( const EuEndlessPThread & );
    //-------------------------------------------------------------------------
 
  protected:
    //========== Static Thread-Methode ========
    //-------------------------------------------------------------------------
    static void * threadWork( void * pParam );
    //-------------------------------------------------------------------------
 
    //========== Methoden ========
    //-------------------------------------------------------------------------
    void takeABreakWait();
    //-------------------------------------------------------------------------
 
  public:
    //========== Methoden ========
    //-------------------------------------------------------------------------
    virtual int start();
    //-------------------------------------------------------------------------
    virtual int cancel();
    //-------------------------------------------------------------------------
    void setExclusiveAccess();
    //-------------------------------------------------------------------------
    void unsetExclusiveAccess();
    //-------------------------------------------------------------------------
    int getBreakCounter();
    //-------------------------------------------------------------------------
    virtual int takeABreak();
    //-------------------------------------------------------------------------
    virtual int finishBreak();
    //-------------------------------------------------------------------------
    void waitForInput();
    //-------------------------------------------------------------------------
    void signalInput();
    //-------------------------------------------------------------------------
 
  private:
    //============== Operatoren
    //-------------------------------------------------------------------------
    EuEndlessPThread & operator= ( const EuEndlessPThread & );
    //-------------------------------------------------------------------------
};
#endif