paco_marcel.cc

Go to the documentation of this file.

#include "paco_marcel.h"

paco_marcel_thread::paco_marcel_thread()
{
}

paco_marcel_thread::~paco_marcel_thread()
{
}

paco_marcel_mutex::paco_marcel_mutex()
{
  marcel_mutex_init(&mutex, 0);
}

paco_marcel_mutex::~paco_marcel_mutex()
{
  marcel_mutex_destroy(&mutex);
}

void
paco_marcel_mutex::lock()
{
  marcel_mutex_lock(&mutex);
}

void
paco_marcel_mutex::unlock()
{
  marcel_mutex_unlock(&mutex);
}


paco_marcel_condition::paco_marcel_condition(paco_marcel_mutex* m)
{
  mutex = m;
  marcel_cond_init(&condition, 0);
}


paco_marcel_condition::~paco_marcel_condition()
{
  marcel_cond_destroy(&condition);
}

void
paco_marcel_condition::wait()
{
  marcel_cond_wait(&condition, &mutex->mutex);
}

void
paco_marcel_condition::signal()
{
  marcel_cond_signal(&condition);
}
  
paco_mutex* paco_marcel_fabrique::paco_create_mutex()
{
  return new paco_marcel_mutex();
}

paco_condition* paco_marcel_fabrique::paco_create_condition(paco_mutex * mutex)
{
  return new paco_marcel_condition((paco_marcel_mutex*) mutex);
}

paco_thread * paco_marcel_fabrique::paco_create_thread(void* (*fn)(void*), void* arg)
{
  marcel_attr_t attr;
  
  marcel_attr_init(&attr);
  // marcel_attr_setdetachstate(&attr, MARCEL_CREATE_DETACHED );

  paco_marcel_thread * th = new paco_marcel_thread();
  marcel_create(&th->thread, &attr, fn,arg);
  padico_tm_thread_givename_tid("PaCO++ thread (joinable)", th->thread);
  return th;
}

paco_thread * paco_marcel_fabrique::paco_create_thread(void (*fn)(void*), void* arg)
{
  marcel_attr_t attr;

  
  marcel_attr_init(&attr);
  marcel_attr_setdetachstate(&attr, MARCEL_CREATE_DETACHED );

  paco_marcel_thread * th = new paco_marcel_thread();
  marcel_create(&th->thread, &attr,  (void* (*)(void*))fn,arg);
  padico_tm_thread_givename_tid("PaCO++ thread (detached)", th->thread);
  return th;
}