thread.cpp

Go to the documentation of this file.

#include "thread.h"
#include <time.h>


namespace CVD {
//Static variables
bool Thread::ourInitializedFlag = false;
pthread_key_t Thread::ourKey;
unsigned int Thread::ourCount;

Thread::Thread() : myRunningFlag(false), myStopFlag(false)
{
   if (!ourInitializedFlag)
     {
    init();
    ourInitializedFlag = true;
     }
}

Thread::~Thread() 
{
   if (isRunning()) 
     {
    stop();
    join();
     }
}

void Thread::start(Runnable* runnable) 
{
    myRunnable = runnable ? runnable : this;
    myStopFlag = false;
    pthread_attr_t attr;
    pthread_attr_init(&attr);
    pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);
    ourCount++;
    pthread_create(&myID, &attr, threadproc, this);
}

void Thread::stop() 
{
   myStopFlag = true;
}

bool Thread::shouldStop() const
{
   return myStopFlag;
}

bool Thread::isRunning() const
{
   return myRunningFlag;
}

void Thread::join() 
{
   pthread_join(myID,0);
}

pthread_t Thread::getID() 
{
   return myID;
}

unsigned int Thread::count() 
{
   return ourCount;
}

Thread* Thread::getCurrent() 
{
   return (Thread*)pthread_getspecific(ourKey);
}

void Thread::sleep(unsigned int milli) 
{
   struct timespec ts = { milli/1000, (milli%1000)*1000000 };
   nanosleep(&ts, 0);

}

//void Thread::yield()
//{
//  pthread_yield_np();
//}

bool Thread::init() 
{
   ourCount = 0;
   pthread_key_create(&ourKey,0);
   return true;
}

void* Thread::threadproc(void* param) 
{
   Thread* thread = (Thread*)param;
   pthread_setspecific(ourKey, thread);
   thread->myRunningFlag = true;
   if (thread->myRunnable)
     thread->myRunnable->run();
   else
     thread->run();
   thread->myRunningFlag = false;
   ourCount--;
   return 0;
}

}