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
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
|
=encoding UTF-8
=head1 НАИМЕНОВАНИЕ
BH_Thread - многопоточность и примитивы синхронизации
=head1 СИНТАКСИС
#include <BH/Thread.h>
cc prog.c -o prog -lbh
=head1 ОПИСАНИЕ
Библиотека BH_Thread предоставляет набор функций для работы с многопоточностью
и синхронизацией потоков. Она включает в себя функции для создания и управления
потоками, работы с мьютексами, семафорами, условными переменными и спинлоками.
=head1 API ВЫЗОВЫ
=head2 BH_ThreadNew
BH_Thread *BH_ThreadNew(size_t stack,
BH_ThreadCallback callback,
void *data);
Создаёт поток с заданным размером стека I<stack>, исполняемой функцией
I<callback> и данными I<data>.
В случае успеха возвращает указатель на объект потока, иначе NULL.
=head2 BH_ThreadJoin
int BH_ThreadJoin(BH_Thread *thread);
Блокирует исполнение текущего потока до завершения другого потока.
По завершении выполнения потока ресурсы I<thread> освобождаются.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_ThreadDetach
int BH_ThreadDetach(BH_Thread *thread);
Отсоединяет поток от текущего процесса.
По завершении выполнения потока ресурсы I<thread> освобождаются.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_ThreadSleep
void BH_ThreadSleep(uint32_t timeout)
Останавливает выполнения потока на указнный промежуток времени.
Параметр I<timeout> задаёт время ожидания в миллисекундах.
=head2 BH_MutexNew
BH_Mutex *BH_MutexNew(void);
Создаёт мьютекс.
В случае успеха возвращает указатель на объект мьютекса, иначе NULL.
=head2 BH_MutexFree
void BH_MutexFree(BH_Mutex *mutex);
Уничтожает мьютекс.
Если мьютекс захвачен, поведение не определено.
=head2 BH_MutexLock
int BH_MutexLock(BH_Mutex *mutex);
Захватывает мьютекс.
Если мьютекс уже был захвачен, поведение не определено.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_MutexUnlock
int BH_MutexUnlock(BH_Mutex *mutex);
Отпускает мьютекс.
Если мьютекс захвачен другим потоком, поведение не определено.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_MutexTryLock
int BH_MutexTryLock(BH_Mutex *mutex);
Производит попытку захвата мьютекса.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_SemaphoreNew
BH_Semaphore *BH_SemaphoreNew(int value);
Создаёт семафор с заданным изначальным значением I<value>.
В случае успеха возвращает указатель на объект семафора, иначе NULL.
=head2 BH_SemaphoreFree
void BH_SemaphoreFree(BH_Semaphore *semaphore);
Уничтожает семафор.
=head2 BH_SemaphorePost
int BH_SemaphorePost(BH_Semaphore *semaphore);
Увеличивает значение семафора на 1.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_SemaphoreWait
int BH_SemaphoreWait(BH_Semaphore *semaphore);
Уменьшает значение семафора на 1.
Если значение семафора равно 0, блокирует выполнение текущего потока до тех пор,
пока значение семафора не станет больше 0.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_SemaphoreTryWait
int BH_SemaphoreTryWait(BH_Semaphore *semaphore);
Пытается уменьшить значение семафора на 1.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_SemaphoreWaitFor
int BH_SemaphoreWaitFor(BH_Semaphore *semaphore,
uint32_t timeout);
Пытается уменьшить значение семафора на 1 в пределах заданного времени
I<timeout>.
Параметр I<timeout> задаёт время ожидания в миллисекундах.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_ConditionNew
BH_Condition *BH_ConditionNew(void);
Создаёт новую условную переменную.
В случае успеха возвращает указатель на объект условной переменной, иначе NULL.
=head2 BH_ConditionFree
void BH_ConditionFree(BH_Condition *condition);
Уничтожает условную переменную.
Если условная переменная используется другими потоками, поведение не определено.
=head2 BH_ConditionWait
int BH_ConditionWait(BH_Condition *condition,
BH_Mutex *mutex);
Блокирует исполнение текущего потока до тех пор, пока другой поток не
просигнализирует об изменении условия.
В некоторых ситуациях сигнал об изменении условия может быть ложным.
Параметр I<mutex> определяет мьютекс, который используется совместно с условной
переменной.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_ConditionWaitFor
int BH_ConditionWaitFor(BH_Condition *condition,
BH_Mutex *mutex,
uint32_t timeout);
Пытается заблокировать исполнение текущего потока до тех пор, пока другой поток
не просигнализирует об изменении условия в пределах заданного времени
I<timeout>.
В некоторых ситуациях сигнал об изменении условия может быть ложным.
Параметр I<mutex> определяет мьютекс, который используется совместно с условной
переменной.
Параметр I<timeout> задаёт время ожидания в миллисекундах.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_ConditionSignal
int BH_ConditionSignal(BH_Condition *condition);
Сигнализирует одному ожидающему потоку об изменении условия.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_ConditionBroadcast
int BH_ConditionBroadcast(BH_Condition *condition);
Сигнализирует всем ожидающим потокам об изменении условия.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_SpinlockLock
void BH_SpinlockLock(int *lock);
Блокирует спинлок.
=head2 BH_SpinlockTryLock
int BH_SpinlockTryLock(int *lock);
Пытается заблокировать спинлок.
В случае успеха возвращает 0, иначе код ошибки.
=head2 BH_SpinlockUnlock
void BH_SpinlockUnlock(int *lock);
Разблокирует спинлок.
=head2 BH_TssCreate
int BH_TssCreate(BH_GenericCallback callback);
Создаёт новый TSS/TLS индекс с функцией очистки I<callback>.
В случае успеха возвращает TSS/TLS индекс, иначе код ошибки.
=head2 BH_TssRead
void *BH_TssRead(int index);
Читает данные из слота TSS/TLS.
=head2 BH_TssWrite
void BH_TssWrite(int index,
void *value);
Записывает данные I<value> в слот TSS/TLS.
=head1 СМ. ТАКЖЕ
L<BH>
|