Search  

---

C:/temp/src/j2k/Posix/Basic_PThread.cpp

Go to the documentation of this file.

// Made by Fred, for Coen445.
// LGPL licensed.

#ifndef __J2K__Basic_PThread_CPP__
#define __J2K__Basic_PThread_CPP__

/*************************************************************************
 **  FILE NAME   : <j2k/445/Posix/Basic_PThread.cpp>                    **
 **  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/445/Posix/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 = FALSE, BOOL autojoin = FALSE )
  : pid( INVALID_PID ), isDetached( TRUE )
 {

    // Increase concurrency level to number of CPU + 3

#if (__sun) || (__SUN__) 

    thr_setconcurrency( sysconf(_SC_NPROCESSORS_ONLN) + 3 );

#endif

   if ( autostart ) start();
   if ( autojoin  ) join();
 }

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

 void Basic_PThread::start( int start_prio )
 {
   if ( pid >= 0 && pid != INVALID_PID ) return;

   memset( &attr,  0, sizeof( attr  ) );
   memset( &param, 0, sizeof( param ) );

   pthread_attr_init( &attr );
   pthread_attr_setscope( &attr, PTHREAD_SCOPE_SYSTEM );
   pthread_attr_setdetachstate( &attr, PTHREAD_CREATE_JOINABLE );
 
   pthread_attr_setinheritsched( &attr, PTHREAD_EXPLICIT_SCHED );   
   pthread_attr_setschedparam( &attr, &param );

   param.sched_priority = start_prio;
   pthread_setschedparam( pthread_self(), SCHED_RR, &param );
   pthread_setschedparam( pid, SCHED_RR, &param );
    
   // Call the static Wrapper() which will call the dynamic run()
   int rc = pthread_create( &pid, &attr, Wrapper, (void*)this );

   if ( rc == -1 ) printf( "Forgot to include libraries:  g++ -lpthread -lrt -lsocket -lnsl -g Basic_PThread.cpp" );

   MC_OnError( rc, Error, "while starting a basic pthread." )

   detach();

   // pthread_exit( NULL );
 }

 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 && 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 = NULL )
 {
   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

---