SynGame/allegro/include/allegro5/platform/aintuthr.h

102 lines
1.9 KiB
C

/*
* UNIX threads
*/
#ifndef __al_included_allegro5_aintuthr_h
#define __al_included_allegro5_aintuthr_h
#include <pthread.h>
#include "allegro5/internal/aintern_thread.h"
#ifdef __cplusplus
extern "C" {
#endif
/* threads */
struct _AL_THREAD
{
/* private: */
pthread_t thread;
pthread_mutex_t mutex;
bool should_stop;
void (*proc)(struct _AL_THREAD *self, void *arg);
void *arg;
};
struct _AL_MUTEX
{
bool inited;
pthread_mutex_t mutex;
};
#define _AL_MUTEX_UNINITED { false, PTHREAD_MUTEX_INITIALIZER }
/* makes no sense, but shuts gcc up */
#define _AL_MARK_MUTEX_UNINITED(M) do { M.inited = false; } while (0)
struct _AL_COND
{
pthread_cond_t cond;
};
typedef struct ALLEGRO_TIMEOUT_UNIX ALLEGRO_TIMEOUT_UNIX;
struct ALLEGRO_TIMEOUT_UNIX
{
struct timespec abstime;
};
AL_INLINE(bool, _al_get_thread_should_stop, (struct _AL_THREAD *t),
{
bool ret;
pthread_mutex_lock(&t->mutex);
ret = t->should_stop;
pthread_mutex_unlock(&t->mutex);
return ret;
})
AL_FUNC(void, _al_mutex_init, (struct _AL_MUTEX*));
AL_FUNC(void, _al_mutex_destroy, (struct _AL_MUTEX*));
AL_INLINE(void, _al_mutex_lock, (struct _AL_MUTEX *m),
{
if (m->inited)
pthread_mutex_lock(&m->mutex);
})
AL_INLINE(void, _al_mutex_unlock, (struct _AL_MUTEX *m),
{
if (m->inited)
pthread_mutex_unlock(&m->mutex);
})
AL_INLINE(void, _al_cond_init, (struct _AL_COND *cond),
{
pthread_cond_init(&cond->cond, NULL);
})
AL_INLINE(void, _al_cond_destroy, (struct _AL_COND *cond),
{
pthread_cond_destroy(&cond->cond);
})
AL_INLINE(void, _al_cond_wait, (struct _AL_COND *cond, struct _AL_MUTEX *mutex),
{
pthread_cond_wait(&cond->cond, &mutex->mutex);
})
AL_INLINE(void, _al_cond_broadcast, (struct _AL_COND *cond),
{
pthread_cond_broadcast(&cond->cond);
})
AL_INLINE(void, _al_cond_signal, (struct _AL_COND *cond),
{
pthread_cond_signal(&cond->cond);
})
#ifdef __cplusplus
}
#endif
#endif