---

threads_posix.cpp

Go to the documentation of this file.

#include <unistd.h>
#include <pthread.h>
#include "threads.h"


namespace audiere {

  struct ThreadInternal {
    AI_ThreadRoutine routine;
    void* opaque;
  };


  struct AI_CriticalSectionStruct {
    pthread_mutex_t mutex;
  };


  void* ThreadRoutine(void* arg) {
    ThreadInternal* ti = (ThreadInternal*)arg;
    ti->routine(ti->opaque);
    delete ti;
    return NULL;
  }


  bool AI_CreateThread(AI_ThreadRoutine routine, void* opaque, int priority) {
    ThreadInternal* ti = new ThreadInternal;
    ti->routine = routine;
    ti->opaque  = opaque;

    pthread_t thread;
    int result = pthread_create(&thread, NULL, ThreadRoutine, ti);
    if (result != 0) {
      delete ti;
      return false;
    } else {
      return true;
    }
  }


  void AI_Sleep(unsigned milliseconds) {
    int seconds = milliseconds / 1000;
    int useconds = (milliseconds % 1000) * 1000;

    sleep(seconds);
    usleep(useconds);
  }


  AI_CriticalSection AI_CreateCriticalSection() {
    AI_CriticalSectionStruct* cs = new AI_CriticalSectionStruct;
    int result = pthread_mutex_init(&cs->mutex, 0);
    if (result != 0) {
      delete cs;
      return NULL;
    }

    return cs;
  }

  void AI_DestroyCriticalSection(AI_CriticalSection cs) {
    pthread_mutex_destroy(&cs->mutex);
  }

  void AI_EnterCriticalSection(AI_CriticalSection cs) {
    pthread_mutex_lock(&cs->mutex);
  }

  void AI_LeaveCriticalSection(AI_CriticalSection cs) {
    pthread_mutex_unlock(&cs->mutex);
  }

}

---