Search  

---

C:/temp/src/j2k/nto/bak2/Basic_PThread.hpp

Go to the documentation of this file.

#ifndef __J2K__Basic_PThread_HPP__
#define __J2K__Basic_PThread_HPP__

/*************************************************************************
 **  FILE NAME   : Basic_PThread.hpp                                    **
 **  CLASS NAME  : Basic_PThread                                        **
 **  DESCRIPTION : This class allows the creation of Generic Thread     **
 **                which takes care of the internals                    **
 **                of the PThread features. Any other subsequent        **
 **                classes can use this thread, or can appear as thread **
 **                just by inheriting from this basic class.            **
 **                just by inheriting from this basic class.            **
 **                just by inheriting from this basic class.            **
 *************************************************************************/


// Default Standard header file
#include <j2k/Fred/Standard.hpp>

//#include <j2k/Fred/Error/JErrorController.hpp>

#include <errno.h>

#define Error 1
#define MC_OnError( x, y, z ) 


#include <pthread.h>
#include <unistd.h>

#if defined( __sun ) || defined( __SUN__ )
#include <thread.h>
#endif

// #include <process.h>

#include <sched.h>

#include <time.h>
#include <signal.h>
#include <sys/types.h>

#define  pid_t   pthread_t

#define  INVALID_PID   ( 255 )

/**************************************************************
***************************************************************
***  Attribute         Default Value                        ***
***  =========         =============                        *** 
***   detachstate       PTHREAD_CREATE_JOINABLE             *** 
***   schedpolicy       PTHREAD_INHERIT_SCHED               ***
***   schedparam        Inherited from parent thread        *** 
***   contentionscope   PTHREAD_SCOPE_SYSTEM                *** 
***   stacksize         4096                                *** 
***   stackaddr         NULL                                ***
***************************************************************
**************************************************************/

class Basic_PThread {
public:

   // Default Constructor
   inline Basic_PThread( BOOL autostart = FALSE, BOOL autojoin = FALSE );

   // Destructor
   inline virtual ~Basic_PThread();

private:
   // Not implemented.
   inline Basic_PThread( const Basic_PThread& src );
   inline const Basic_PThread& operator=( const Basic_PThread& src );

public:
   // Get calling thread's ID
   inline pid_t getPID();
 

   // Implement this, when deriving the class.
   // It should be overriden by it's children...
   virtual void run() = 0;


   //  Callback can only call STATIC functions !
   //  =========================================
   //  This routine is a stub which will call
   //  the run() routine given the class instance
   //  as the void pointer argument.

   static void* Basic_PThread::Wrapper( void* ptrThis ) 
   {
     Basic_PThread* me = (Basic_PThread*)ptrThis;
 
     // Call the derived classes version, since the function
     // run is implemented by it's children
     me->run();  

     // run() should contain an Infinite Loop, i.e. for(;;) { ... }
     // Exit beautifully, just in case there is no infinite loop.
  
     me->pid = INVALID_PID; 
     pthread_exit( NULL );
 
     return NULL;
   }

   // Start the PThread with the given priority
//   inline void startrel( int p ) 
//   {
//     start( getprio( 0 ) + p );
//   }

   void start( int start_prio = 10 );

   // Let other threads run, I'm done for now... via sched_yield()
   inline void yield();

   // Cancel a PThread and make it invalid.
   inline void stop();

   // Exit a PThread
   inline void end();

   // Is this PThread started ?
   inline BOOL isStarted();

   // Join PThread
   inline void join( void** value_ptr = NULL );

   // Detach a Join PThread 
   inline void detach();
    
protected:
  // So, children can access easily the PID
  pid_t            pid; 
  BOOL             isDetached;
  pthread_attr_t   attr;
  sched_param      param;
  int              priority;
};

#include <j2k/nto/Basic_PThread.inl>

#endif

---