TGo4Thread.h

Go to the documentation of this file.

// $Id$
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum fuer Schwerionenforschung GmbH
//                     Planckstr. 1, 64291 Darmstadt, Germany
// Contact:            http://go4.gsi.de
//-----------------------------------------------------------------------
// This software can be used under the license agreements as stated
// in Go4License.txt file which is part of the distribution.
//-----------------------------------------------------------------------
 
#ifndef TGo4Thread_H
#define TGo4Thread_H
 
#include "TNamed.h"
 
class TThread;
class TCondition;
class TGo4Runnable;

 
class TGo4Thread : public TNamed {
 
   public:
 
      TGo4Thread() = delete;
 
      TGo4Thread(const TGo4Thread &right);

      TGo4Thread (const char *name, TGo4Runnable *runnable, Bool_t internal = kTRUE);
 
      virtual ~TGo4Thread();

      Bool_t Create();

      Bool_t Cancel();

      Bool_t ReCreate();

      Bool_t Start();

      Bool_t Stop();

      static void Sleep(UInt_t millisecs);

      Int_t GetPID() const { return fiThreadPID; }

      Long_t GetSelfID() const { return fiThreadSelfID; }

      Bool_t IsInternal() const { return fbIsInternal; }

      Bool_t IsCreated() const { return fbIsCreated; }

      Bool_t IsRunning() const { return fbIsRunning; }

      Bool_t IsWaiting() const { return fbIsWaiting; }
 
   private:

      static void Threadfunc (void *arg);

      TGo4Runnable *GetRunnable() const { return fxRunnable; }
 
      TCondition *GetCondition() const { return fxCondition; }
 
      void SetPID();
 
      void SetSelfID();
 
      void SetWaiting(Bool_t mode=kTRUE) { fbIsWaiting=mode; }

      Bool_t fbIsInternal{kFALSE};

      Bool_t fbIsCreated{kFALSE};

      Bool_t fbIsRunning{kFALSE};

      Int_t fiThreadPID{0};

      Long_t fiThreadSelfID{0};

      Bool_t fbIsWaiting{kFALSE};

      TGo4Runnable *fxRunnable{nullptr}; 
 
      TThread *fxThread{nullptr};  
 
      TCondition *fxCondition{nullptr};  
};
 
#endif