threads.h

Go to the documentation of this file.

#ifndef LELY_LIBC_THREADS_H_
#define LELY_LIBC_THREADS_H_

#include <lely/features.h>

// clang-format off
#ifndef LELY_HAVE_THREADS_H
#if __STDC_VERSION__ >= 201112L && !defined(__STDC_NO_THREADS__)
#define LELY_HAVE_THREADS_H 1
#endif
#endif
// clang-format on

//#if LELY_HAVE_THREADS_H
//#include <threads.h>
//#else // !LELY_HAVE_UNISTD_H

#include <lely/libc/time.h>

#ifndef LELY_HAVE_PTHREAD_H
#if _POSIX_THREADS >= 200112L || defined(__MINGW32__)
#define LELY_HAVE_PTHREAD_H 1
#endif
#endif

#if LELY_HAVE_PTHREAD_H
#include <pthread.h>
#elif _WIN32
#include <windows.h>
#else
#error This file requires POSIX Threads or Windows.
#endif

#ifndef thread_local
#if __cplusplus >= 201103L
// thread_local is a keyword in C++11 and later.
#else
#define thread_local _Thread_local
#endif
#endif

#if LELY_HAVE_PTHREAD_H
#define ONCE_FLAG_INIT PTHREAD_ONCE_INIT
#elif _WIN32
#define ONCE_FLAG_INIT 0
#endif

#define TSS_DTOR_ITERATIONS 1

#if LELY_HAVE_PTHREAD_H
typedef pthread_cond_t cnd_t;
#elif _WIN32
typedef CONDITION_VARIABLE cnd_t;
#endif

#if LELY_HAVE_PTHREAD_H
typedef pthread_t thrd_t;
#elif _WIN32
typedef void *thrd_t;
#endif

#if LELY_HAVE_PTHREAD_H
typedef pthread_key_t tss_t;
#elif _WIN32
typedef DWORD tss_t;
#endif

#if LELY_HAVE_PTHREAD_H
typedef pthread_mutex_t mtx_t;
#elif _WIN32
typedef CRITICAL_SECTION mtx_t;
#endif

enum {
        mtx_plain = 0,
        mtx_recursive = 2,
        mtx_timed = 1
};

enum {
        thrd_success,
        thrd_error,
        thrd_timedout,
        thrd_busy,
        thrd_nomem
};

#if LELY_HAVE_PTHREAD_H
typedef pthread_once_t once_flag;
#elif _WIN32
typedef long once_flag;
#endif

#ifdef __cplusplus
extern "C" {
#endif

#if LELY_HAVE_PTHREAD_H
typedef void (*tss_dtor_t)(void *);
#elif _WIN32
// clang-format off
typedef void (WINAPI *tss_dtor_t)(void *);
// clang-format on
#endif

typedef void *(*thrd_start_t)(void *);

void call_once(once_flag *flag, void (*func)(void));

int cnd_broadcast(cnd_t *cond);

void cnd_destroy(cnd_t *cond);

int cnd_init(cnd_t *cond);

int cnd_signal(cnd_t *cond);

int cnd_timedwait(cnd_t *cond, mtx_t *mtx, const struct timespec *ts);

int cnd_wait(cnd_t *cond, mtx_t *mtx);

void mtx_destroy(mtx_t *mtx);

int mtx_init(mtx_t *mtx, int type);

int mtx_lock(mtx_t *mtx);

int mtx_timedlock(mtx_t *mtx, const struct timespec *ts);

int mtx_trylock(mtx_t *mtx);

int mtx_unlock(mtx_t *mtx);

int thrd_create(thrd_t *thr, thrd_start_t func, void *arg);

thrd_t thrd_current(void);

int thrd_detach(thrd_t thr);

int thrd_equal(thrd_t thr0, thrd_t thr1);

_Noreturn void thrd_exit(int res);

int thrd_join(thrd_t thr, int *res);

int thrd_sleep(const struct timespec *duration, struct timespec *remaining);

void thrd_yield(void);

int tss_create(tss_t *key, tss_dtor_t dtor);

void tss_delete(tss_t key);

void *tss_get(tss_t key);

int tss_set(tss_t key, void *val);

#ifdef __cplusplus
}
#endif

//#endif // !LELY_HAVE_THREADS_H

#endif // !LELY_LIBC_THREADS_H_