1 files changed, 132 insertions, 0 deletions
diff --git a/source/kit/threads.h b/source/kit/threads.h
new file mode 100644
index 0000000..8ff46ed
--- /dev/null
+++ b/source/kit/threads.h
@@ -0,0 +1,132 @@
+#ifndef KIT_THREADS_H
+#define KIT_THREADS_H
+#ifndef KIT_DISABLE_SYSTEM_THREADS
+
+#  include "time.h"
+
+#  include <stddef.h>
+#  include <stdint.h>
+
+#  if !defined(_WIN32) || defined(__CYGWIN__)
+#    include <pthread.h>
+#  endif
+
+#  if defined(__cplusplus)
+#    define _Noreturn [[noreturn]]
+#  elif defined(_MSC_VER)
+#    define _Noreturn __declspec(noreturn)
+#  endif
+
+#  ifndef _Thread_local
+#    if defined(__cplusplus)
+//  C++11 doesn't need `_Thread_local` keyword or macro
+#    elif !defined(__STDC_NO_THREADS__)
+//  threads are optional in C11, _Thread_local present in this
+//  condition
+#    elif defined(_MSC_VER)
+#      define _Thread_local __declspec(thread)
+#    elif defined(__GNUC__)
+#      define _Thread_local __thread
+#    else
+//  Leave _Thread_local undefined so that use of _Thread_local would
+//  not promote to a non-thread-local global variable
+#    endif
+#  endif
+
+#  if !defined(__cplusplus)
+//  C11 thread_local() macro C++11 and above already have thread_local
+//  keyword
+#    ifndef thread_local
+#      if _MSC_VER
+#        define thread_local __declspec(thread)
+#      else
+#        define thread_local _Thread_local
+#      endif
+#    endif
+#  endif
+
+#  ifdef __cplusplus
+extern "C" {
+#  endif
+
+enum {
+  mtx_plain,
+  mtx_recursive,
+  mtx_timed,
+};
+
+enum {
+  thrd_success,
+  thrd_timedout,
+  thrd_error,
+  thrd_busy,
+  thrd_nomem,
+  thrd_wrong_stack_size
+};
+
+#  if defined(_WIN32) && !defined(__CYGWIN__)
+typedef struct {
+  void     *DebugInfo;
+  long      LockCount;
+  long      RecursionCount;
+  void     *OwningThread;
+  void     *LockSemaphore;
+  uintptr_t SpinCount;
+} mtx_t;
+
+typedef struct {
+  void *Ptr;
+} cnd_t;
+
+typedef struct {
+  volatile uintptr_t status;
+} once_flag;
+
+typedef struct {
+  void *handle;
+} thrd_t;
+
+typedef unsigned long tss_t;
+#  else
+typedef pthread_mutex_t mtx_t;
+typedef pthread_cond_t  cnd_t;
+typedef pthread_once_t  once_flag;
+typedef pthread_t       thrd_t;
+typedef pthread_key_t   tss_t;
+#  endif
+
+typedef void (*tss_dtor_t)(void *);
+typedef int (*thrd_start_t)(void *);
+
+void   mtx_destroy(mtx_t *mtx_);
+int    mtx_init(mtx_t *mtx_, int);
+int    mtx_lock(mtx_t *mtx_);
+int    mtx_timedlock(mtx_t *__restrict mtx_,
+                     struct timespec const *__restrict);
+int    mtx_trylock(mtx_t *mtx_);
+int    mtx_unlock(mtx_t *mtx_);
+void   call_once(once_flag *, void (*)(void));
+int    cnd_broadcast(cnd_t *);
+void   cnd_destroy(cnd_t *);
+int    cnd_init(cnd_t *);
+int    cnd_signal(cnd_t *);
+int    cnd_timedwait(cnd_t *__restrict, mtx_t *__restrict mtx_,
+                     struct timespec const *__restrict);
+int    cnd_wait(cnd_t *, mtx_t *mtx_);
+int    thrd_create(thrd_t *, thrd_start_t, void *);
+int    thrd_create_with_stack(thrd_t *, thrd_start_t, void *,
+                              ptrdiff_t stack_size);
+thrd_t thrd_current(void);
+int    thrd_detach(thrd_t);
+int    thrd_equal(thrd_t, thrd_t);
+_Noreturn void thrd_exit(int);
+int            thrd_join(thrd_t, int *);
+int            thrd_sleep(struct timespec const *, struct timespec *);
+void           thrd_yield(void);
+
+#  ifdef __cplusplus
+}
+#  endif
+
+#endif
+#endif