---

core/thread.cpp

Go to the documentation of this file.

#include "thread.h"
#include "mem/memory.cpp"

#ifndef _CORE_THREAD_CPP_
#define _CORE_THREAD_CPP_

static const char thdid[] = "\100$ Free Agent: thread.cpp, v 0.1 2002/05/29 red0x Exp $";

Thread::Thread()
{
    p_mutex = NULL;
    agent_new(&p_mutex);
    {assert(p_mutex != NULL);}
    pthread_mutex_init(p_mutex, NULL);
}

Thread::~Thread()
{
    {assert(p_mutex != NULL);}
    pthread_mutex_destroy(p_mutex);
}

int Thread::Start(void * arg)
{
   Arg(arg); // store user data
   int code = pthread_create(&a_thread, NULL, (void *(*) (void *))
        Thread::EntryPoint, (void *) this);
   return code;
}

int Thread::Run(void * arg)
{
   Setup();
   Execute(arg);
   return 0;
}

/*static */
void *Thread::EntryPoint(void *pthis)
{
   Thread * pt = (Thread*)pthis;
   pt->Run(pt->Arg());
   return pt;
}

void Thread::Setup()
{
        // Do any setup here
}

void Thread::Execute(void* arg)
{
        // Your code goes here
}

void Thread::Lock()
{
    pthread_mutex_lock(p_mutex);
}

void Thread::Unlock()
{
    pthread_mutex_unlock(p_mutex);
}
#endif

---