Search  

---

C:/temp/src/j2k/Deprecated/old_18mar_diff/nto/Basic_PThread.inl

Go to the documentation of this file.

#ifndef Basic_PThread_INL
#define Basic_PThread_INL

/*************************************************************************
 **  FILE NAME   : Basic_PThread.inl                                    **
 **  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.            **
 *************************************************************************/

#include <j2k/nto/Basic_PThread.hpp>

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

 // Default Constructor
 // Assign default values and set PID = -1
 // to indicate that no thread was created yet.

 inline Basic_PThread::Basic_PThread( BOOL autostart, BOOL autojoin )
  : pid( INVALID_PID ), isDetached( TRUE )
 {
   if ( autostart ) start();
   if ( autojoin  ) join();
 }

 // Virtual Destructor
 inline Basic_PThread::~Basic_PThread() 
 {
   stop();
   end();
 }

 inline void Basic_PThread::stop() {
   if ( pid < 0 ) return;
 
   pthread_cancel( pid );
   pid = INVALID_PID;
 }

 inline void Basic_PThread::end() {
   pthread_exit( NULL );
 }

 inline pid_t Basic_PThread::getPID() 
 {
   return pid;
 }

 inline BOOL Basic_PThread::isStarted() 
 {
   return ( pid >= 0 && (signed long)pid != INVALID_PID );
 }

 inline void Basic_PThread::yield() 
 {
   sched_yield();
 }

 inline void Basic_PThread::detach()
 {
   if ( pid < 0    ) return;
   if ( isDetached ) return;
    
   int err = pthread_detach( pid );
   isDetached = TRUE;
    
   MC_OnError( err, Error, "An error occured while detaching a PThread." );
 }

 // Join Basic_PThread
 inline void Basic_PThread::join( void** value_ptr )
 {
   int err = 0;
   if ( pid < 0 ) return;
   if ( !isDetached )
     err = pthread_join( pid, value_ptr );
   
    isDetached = FALSE;
    MC_OnError( err, Error, "An error occured while joining a PThread." );
  }

#endif

---