---

PosixThread.cpp

Go to the documentation of this file.

#include <unistd.h>
#include "OSDependent/Posix/PosixThread.h"

extern "C" void *threadEntry(void *arg);

PosixThread::PosixThread(Runnable *runnable) :
_tid(0),
_runnable(runnable)
{
}

PosixThread::~PosixThread()
{
}

int 
PosixThread::start()
{
  return ::pthread_create(&_tid, NULL, threadEntry, _runnable);
}

int 
PosixThread::join()
{
  return ::pthread_join(_tid, NULL);
}

void 
PosixThread::sleep(long msec)
{
  struct timeval timeout;
  timeout.tv_sec = msec / 1000;
  timeout.tv_usec = (msec % 1000) * 1000;
  ::select(0, (fd_set *)0, (fd_set *)0, (fd_set *)0, &timeout);
}

void *
threadEntry(void *arg)
{
  Runnable *runnable = (Runnable *)arg;
  runnable->run();
  return NULL;
}

---