1 | |
2 | #ifndef Py_PYTHREAD_H |
3 | #define Py_PYTHREAD_H |
4 | |
5 | typedef void *PyThread_type_lock; |
6 | |
7 | #ifdef __cplusplus |
8 | extern "C" { |
9 | #endif |
10 | |
11 | /* Return status codes for Python lock acquisition. Chosen for maximum |
12 | * backwards compatibility, ie failure -> 0, success -> 1. */ |
13 | typedef enum PyLockStatus { |
14 | PY_LOCK_FAILURE = 0, |
15 | PY_LOCK_ACQUIRED = 1, |
16 | PY_LOCK_INTR |
17 | } PyLockStatus; |
18 | |
19 | #ifndef Py_LIMITED_API |
20 | #define PYTHREAD_INVALID_THREAD_ID ((unsigned long)-1) |
21 | #endif |
22 | |
23 | PyAPI_FUNC(void) PyThread_init_thread(void); |
24 | PyAPI_FUNC(unsigned long) PyThread_start_new_thread(void (*)(void *), void *); |
25 | PyAPI_FUNC(void) _Py_NO_RETURN PyThread_exit_thread(void); |
26 | PyAPI_FUNC(unsigned long) PyThread_get_thread_ident(void); |
27 | |
28 | #if defined(__APPLE__) || defined(__linux__) || defined(__FreeBSD__) || defined(__FreeBSD_kernel__) || defined(__OpenBSD__) || defined(__NetBSD__) || defined(_WIN32) || defined(_AIX) || defined(__GNU__) |
29 | #define PY_HAVE_THREAD_NATIVE_ID |
30 | PyAPI_FUNC(unsigned long) PyThread_get_thread_native_id(void); |
31 | #endif |
32 | |
33 | PyAPI_FUNC(PyThread_type_lock) PyThread_allocate_lock(void); |
34 | PyAPI_FUNC(void) PyThread_free_lock(PyThread_type_lock); |
35 | PyAPI_FUNC(int) PyThread_acquire_lock(PyThread_type_lock, int); |
36 | #define WAIT_LOCK 1 |
37 | #define NOWAIT_LOCK 0 |
38 | |
39 | #ifndef Py_LIMITED_API |
40 | #ifdef HAVE_FORK |
41 | /* Private function to reinitialize a lock at fork in the child process. |
42 | Reset the lock to the unlocked state. |
43 | Return 0 on success, return -1 on error. */ |
44 | PyAPI_FUNC(int) _PyThread_at_fork_reinit(PyThread_type_lock *lock); |
45 | #endif /* HAVE_FORK */ |
46 | #endif /* !Py_LIMITED_API */ |
47 | |
48 | /* PY_TIMEOUT_T is the integral type used to specify timeouts when waiting |
49 | on a lock (see PyThread_acquire_lock_timed() below). |
50 | PY_TIMEOUT_MAX is the highest usable value (in microseconds) of that |
51 | type, and depends on the system threading API. |
52 | |
53 | NOTE: this isn't the same value as `_thread.TIMEOUT_MAX`. The _thread |
54 | module exposes a higher-level API, with timeouts expressed in seconds |
55 | and floating-point numbers allowed. |
56 | */ |
57 | #define PY_TIMEOUT_T long long |
58 | |
59 | #if defined(_POSIX_THREADS) |
60 | /* PyThread_acquire_lock_timed() uses _PyTime_FromNanoseconds(us * 1000), |
61 | convert microseconds to nanoseconds. */ |
62 | # define PY_TIMEOUT_MAX (LLONG_MAX / 1000) |
63 | #elif defined (NT_THREADS) |
64 | /* In the NT API, the timeout is a DWORD and is expressed in milliseconds */ |
65 | # if 0xFFFFFFFFLL * 1000 < LLONG_MAX |
66 | # define PY_TIMEOUT_MAX (0xFFFFFFFFLL * 1000) |
67 | # else |
68 | # define PY_TIMEOUT_MAX LLONG_MAX |
69 | # endif |
70 | #else |
71 | # define PY_TIMEOUT_MAX LLONG_MAX |
72 | #endif |
73 | |
74 | |
75 | /* If microseconds == 0, the call is non-blocking: it returns immediately |
76 | even when the lock can't be acquired. |
77 | If microseconds > 0, the call waits up to the specified duration. |
78 | If microseconds < 0, the call waits until success (or abnormal failure) |
79 | |
80 | microseconds must be less than PY_TIMEOUT_MAX. Behaviour otherwise is |
81 | undefined. |
82 | |
83 | If intr_flag is true and the acquire is interrupted by a signal, then the |
84 | call will return PY_LOCK_INTR. The caller may reattempt to acquire the |
85 | lock. |
86 | */ |
87 | PyAPI_FUNC(PyLockStatus) PyThread_acquire_lock_timed(PyThread_type_lock, |
88 | PY_TIMEOUT_T microseconds, |
89 | int intr_flag); |
90 | |
91 | PyAPI_FUNC(void) PyThread_release_lock(PyThread_type_lock); |
92 | |
93 | PyAPI_FUNC(size_t) PyThread_get_stacksize(void); |
94 | PyAPI_FUNC(int) PyThread_set_stacksize(size_t); |
95 | |
96 | #if !defined(Py_LIMITED_API) || Py_LIMITED_API+0 >= 0x03030000 |
97 | PyAPI_FUNC(PyObject*) PyThread_GetInfo(void); |
98 | #endif |
99 | |
100 | |
101 | /* Thread Local Storage (TLS) API |
102 | TLS API is DEPRECATED. Use Thread Specific Storage (TSS) API. |
103 | |
104 | The existing TLS API has used int to represent TLS keys across all |
105 | platforms, but it is not POSIX-compliant. Therefore, the new TSS API uses |
106 | opaque data type to represent TSS keys to be compatible (see PEP 539). |
107 | */ |
108 | Py_DEPRECATED(3.7) PyAPI_FUNC(int) PyThread_create_key(void); |
109 | Py_DEPRECATED(3.7) PyAPI_FUNC(void) PyThread_delete_key(int key); |
110 | Py_DEPRECATED(3.7) PyAPI_FUNC(int) PyThread_set_key_value(int key, |
111 | void *value); |
112 | Py_DEPRECATED(3.7) PyAPI_FUNC(void *) PyThread_get_key_value(int key); |
113 | Py_DEPRECATED(3.7) PyAPI_FUNC(void) PyThread_delete_key_value(int key); |
114 | |
115 | /* Cleanup after a fork */ |
116 | Py_DEPRECATED(3.7) PyAPI_FUNC(void) PyThread_ReInitTLS(void); |
117 | |
118 | |
119 | #if !defined(Py_LIMITED_API) || Py_LIMITED_API+0 >= 0x03070000 |
120 | /* New in 3.7 */ |
121 | /* Thread Specific Storage (TSS) API */ |
122 | |
123 | typedef struct _Py_tss_t Py_tss_t; /* opaque */ |
124 | |
125 | #ifndef Py_LIMITED_API |
126 | #if defined(_POSIX_THREADS) |
127 | /* Darwin needs pthread.h to know type name the pthread_key_t. */ |
128 | # include <pthread.h> |
129 | # define NATIVE_TSS_KEY_T pthread_key_t |
130 | #elif defined(NT_THREADS) |
131 | /* In Windows, native TSS key type is DWORD, |
132 | but hardcode the unsigned long to avoid errors for include directive. |
133 | */ |
134 | # define NATIVE_TSS_KEY_T unsigned long |
135 | #else |
136 | # error "Require native threads. See https://bugs.python.org/issue31370" |
137 | #endif |
138 | |
139 | /* When Py_LIMITED_API is not defined, the type layout of Py_tss_t is |
140 | exposed to allow static allocation in the API clients. Even in this case, |
141 | you must handle TSS keys through API functions due to compatibility. |
142 | */ |
143 | struct _Py_tss_t { |
144 | int _is_initialized; |
145 | NATIVE_TSS_KEY_T _key; |
146 | }; |
147 | |
148 | #undef NATIVE_TSS_KEY_T |
149 | |
150 | /* When static allocation, you must initialize with Py_tss_NEEDS_INIT. */ |
151 | #define Py_tss_NEEDS_INIT {0} |
152 | #endif /* !Py_LIMITED_API */ |
153 | |
154 | PyAPI_FUNC(Py_tss_t *) PyThread_tss_alloc(void); |
155 | PyAPI_FUNC(void) PyThread_tss_free(Py_tss_t *key); |
156 | |
157 | /* The parameter key must not be NULL. */ |
158 | PyAPI_FUNC(int) PyThread_tss_is_created(Py_tss_t *key); |
159 | PyAPI_FUNC(int) PyThread_tss_create(Py_tss_t *key); |
160 | PyAPI_FUNC(void) PyThread_tss_delete(Py_tss_t *key); |
161 | PyAPI_FUNC(int) PyThread_tss_set(Py_tss_t *key, void *value); |
162 | PyAPI_FUNC(void *) PyThread_tss_get(Py_tss_t *key); |
163 | #endif /* New in 3.7 */ |
164 | |
165 | #ifdef __cplusplus |
166 | } |
167 | #endif |
168 | |
169 | #endif /* !Py_PYTHREAD_H */ |
170 | |