/home/fb/sf/compp/trunk/ComPP/ComPlusPlus/Thread.cpp

Go to the documentation of this file.

// **************************************************************
// Com ++ Framework by the C++ World
// Please report defects: mailto:compp@cplusplusworld.com
// Please visit: http://www.cplusplusworld.com/socketlibrary.html
// **************************************************************

#include <iostream>

#include "SysPlusPlus/syscall.h"
#include "ComPlusPlus/Thread.h"
#include "SysPlusPlus/ComException.h"
#include <signal.h>


void compp::Thread::InitPThr() {

  PThr_id = 0;

  PAttr = NULL;

  Arguments = NULL;
}



compp::Thread::Thread() {

  InitPThr();

}


compp::Thread::~Thread() {
}

compp::Thread::Thread(void *arg) {

  InitPThr();
  
  Start ( arg );

}


static void *sfunc (void* v ) {

  compp::Thread * f = (compp::Thread *) v;
  
  f->StartThreadFunc();
  return NULL;
}


void * compp::Thread::StartThreadFunc( ) {

  Run ( Arguments );
  return NULL;
}

bool compp::Thread::Start ( void *arg ) {

  Arguments = arg;
  int i;
  i = syspp::Call::Pthread_create ( &PThr_id, NULL,  sfunc,  this ) ;

  if ( i != 0  ) {
        std::cout << "Thread cannot be created.\n";
        throw syspp::ComException ( "Cannot create thread." );
  }

  return true;
}


bool compp::Thread::Join ( void **value_ptr  ) {
int i;

  i = syspp::Call::Pthread_join ( PThr_id, value_ptr );
  return i ? false : true;

}
bool compp::Thread::Detach ( ) {
int i;

  i = syspp::Call::Pthread_detach ( PThr_id );
  return i ? false : true;

}

bool compp::Thread::Terminate ( ) {
  int j=0;

  pthread_exit ( &j );
  return true;
}

---