thread.h

Go to the documentation of this file.

// ##########################################################################
// ####                                                                  ####
// ####                      RTP Audio Server Project                    ####
// ####                    ============================                  ####
// ####                                                                  ####
// #### Thread                                                           ####
// ####                                                                  ####
// #### Version 1.00  --  February 16, 2001                              ####
// ####                                                                  ####
// #### Copyright (C) 1999  Thomas Dreibholz                             ####
// ####               2000  Universität Bonn, Abt. IV                    ####
// ####               2001  EMail: dreibh@iem.uni-due.de                 ####
// ####                     WWW:   https://www.uni-due.de/~be0001        ####
// ####                                                                  ####
// ##########################################################################


#ifndef THREAD_H
#define THREAD_H


#include "system.h"
#include "synchronizable.h"


#include <pthread.h>


namespace Coral {


class Thread : public Synchronizable
{
   // ====== Constants ======================================================
   public:
   static const cardinal ThreadCancelAsynchronous = 0;
   static const cardinal ThreadCancelDeferred     = (1 << 0);


   // ====== Constructor/Destructor =========================================
   public:
   Thread(const cardinal flags = ThreadCancelAsynchronous);
   
   virtual ~Thread();


   // ====== Status =========================================================
   inline bool running() const;

   
   // ====== Delay ==========================================================
   static card64 delay(const card64 delayTimeout, const bool interruptable = false);

   
   // ====== Thread control =================================================
   virtual bool start();
   
   virtual void stop();
   
   cardinal join();

   virtual void cancel();
   
   virtual void suspend();
   
   virtual void resume();

   
   // ====== Tests for cancellation and suspension ==========================
   protected:
   virtual void testCancel();
   
   virtual bool testSuspension();
   
   inline static void exit(const cardinal result = 0);

   inline static void yield();


   // ====== run() method to be implemented by subclass =====================
   protected:
   virtual void run() = 0;


   // ====== Private data ===================================================
   protected:
   pthread_t       PThread;


   private:
   static void* go(void* i);

   
   private:
   pthread_mutex_t SuspensionMutex;
   cardinal        Flags;
   bool            IsSuspended;
};


}


#include "thread.icc"


#endif