1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
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
|
