StarPU Handbook
starpu_thread.h
Go to the documentation of this file.
1 /* StarPU --- Runtime system for heterogeneous multicore architectures.
2  *
3  * Copyright (C) 2013,2015-2017 Inria
4  * Copyright (C) 2010-2015,2017,2019 CNRS
5  * Copyright (C) 2010,2012-2019 Université de Bordeaux
6  *
7  * StarPU is free software; you can redistribute it and/or modify
8  * it under the terms of the GNU Lesser General Public License as published by
9  * the Free Software Foundation; either version 2.1 of the License, or (at
10  * your option) any later version.
11  *
12  * StarPU is distributed in the hope that it will be useful, but
13  * WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
15  *
16  * See the GNU Lesser General Public License in COPYING.LGPL for more details.
17  */
18 
19 // The documentation for this file is in doc/doxygen/chapters/api/threads.doxy
20 
21 #ifndef __STARPU_THREAD_H__
22 #define __STARPU_THREAD_H__
23 
24 #include <starpu_config.h>
25 #include <starpu_util.h>
26 #ifdef STARPU_SIMGRID
27 #include <pthread.h>
28 #ifdef STARPU_HAVE_XBT_SYNCHRO_H
29 #include <xbt/synchro.h>
30 #else
31 #include <xbt/synchro_core.h>
32 #endif
33 #ifdef STARPU_HAVE_SIMGRID_MSG_H
34 #include <simgrid/msg.h>
35 #else
36 #include <msg/msg.h>
37 #endif
38 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU)
39 #include <pthread.h>
40 #include <semaphore.h>
41 #endif
42 #include <stdint.h>
43 
44 #ifdef __cplusplus
45 extern "C"
46 {
47 #endif
48 
49 /*
50  * Encapsulation of the pthread_create function.
51  */
52 
53 #ifdef STARPU_SIMGRID
54 
55 typedef msg_process_t starpu_pthread_t;
56 typedef int starpu_pthread_attr_t;
57 
58 int starpu_pthread_equal(starpu_pthread_t t1, starpu_pthread_t t2);
59 starpu_pthread_t starpu_pthread_self(void);
60 int starpu_pthread_create_on(char *name, starpu_pthread_t *thread, const starpu_pthread_attr_t *attr, void *(*start_routine) (void *), void *arg, msg_host_t host);
61 int starpu_pthread_create(starpu_pthread_t *thread, const starpu_pthread_attr_t *attr, void *(*start_routine) (void *), void *arg);
62 int starpu_pthread_join(starpu_pthread_t thread, void **retval);
64 int starpu_pthread_attr_init(starpu_pthread_attr_t *attr);
65 int starpu_pthread_attr_destroy(starpu_pthread_attr_t *attr);
66 int starpu_pthread_attr_setdetachstate(starpu_pthread_attr_t *attr, int detachstate);
67 
68 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) /* STARPU_SIMGRID */
69 
70 typedef pthread_t starpu_pthread_t;
71 typedef pthread_attr_t starpu_pthread_attr_t;
72 
73 #define starpu_pthread_equal pthread_equal
74 #define starpu_pthread_self pthread_self
75 #define starpu_pthread_create pthread_create
76 #define starpu_pthread_create_on(name, thread, attr, routine, arg, where) starpu_pthread_create(thread, attr, routine, arg)
77 #define starpu_pthread_join pthread_join
78 #define starpu_pthread_exit pthread_exit
79 #define starpu_pthread_attr_init pthread_attr_init
80 #define starpu_pthread_attr_destroy pthread_attr_destroy
81 #define starpu_pthread_attr_setdetachstate pthread_attr_setdetachstate
82 
83 #endif /* STARPU_SIMGRID, _MSC_VER */
84 
85 #ifdef STARPU_HAVE_PTHREAD_SETNAME_NP
86 #ifdef STARPU_HAVE_DARWIN
87 #define starpu_pthread_setname(name) pthread_setname_np(name)
88 #else
89 #define starpu_pthread_setname(name) pthread_setname_np(pthread_self(), name)
90 #endif
91 #else
92 #define starpu_pthread_setname(name)
93 #endif
94 
95 /*
96  * Encapsulation of the pthread_mutex_* functions.
97  */
98 
99 #ifdef STARPU_SIMGRID
100 typedef xbt_mutex_t starpu_pthread_mutex_t;
101 typedef int starpu_pthread_mutexattr_t;
102 
103 #define STARPU_PTHREAD_MUTEX_INITIALIZER NULL
104 
105 int starpu_pthread_mutex_init(starpu_pthread_mutex_t *mutex, const starpu_pthread_mutexattr_t *mutexattr);
106 int starpu_pthread_mutex_destroy(starpu_pthread_mutex_t *mutex);
107 int starpu_pthread_mutex_lock(starpu_pthread_mutex_t *mutex);
108 int starpu_pthread_mutex_unlock(starpu_pthread_mutex_t *mutex);
109 int starpu_pthread_mutex_trylock(starpu_pthread_mutex_t *mutex);
110 int starpu_pthread_mutexattr_gettype(const starpu_pthread_mutexattr_t *attr, int *type);
111 int starpu_pthread_mutexattr_settype(starpu_pthread_mutexattr_t *attr, int type);
112 int starpu_pthread_mutexattr_destroy(starpu_pthread_mutexattr_t *attr);
113 int starpu_pthread_mutexattr_init(starpu_pthread_mutexattr_t *attr);
114 
115 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) /* !STARPU_SIMGRID */
116 
117 typedef pthread_mutex_t starpu_pthread_mutex_t;
118 typedef pthread_mutexattr_t starpu_pthread_mutexattr_t;
119 
120 #define starpu_pthread_mutex_init pthread_mutex_init
121 #define starpu_pthread_mutex_destroy pthread_mutex_destroy
122 #define starpu_pthread_mutexattr_gettype pthread_mutexattr_gettype
123 #define starpu_pthread_mutexattr_settype pthread_mutexattr_settype
124 #define starpu_pthread_mutexattr_destroy pthread_mutexattr_destroy
125 #define starpu_pthread_mutexattr_init pthread_mutexattr_init
126 
127 #ifdef STARPU_FXT_LOCK_TRACES
128 int starpu_pthread_mutex_lock(starpu_pthread_mutex_t *mutex);
129 int starpu_pthread_mutex_unlock(starpu_pthread_mutex_t *mutex);
130 int starpu_pthread_mutex_trylock(starpu_pthread_mutex_t *mutex);
131 #else
132 #define starpu_pthread_mutex_lock pthread_mutex_lock
133 #define starpu_pthread_mutex_unlock pthread_mutex_unlock
134 #define starpu_pthread_mutex_trylock pthread_mutex_trylock
135 #endif
136 
137 #define STARPU_PTHREAD_MUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER
138 
139 #endif /* STARPU_SIMGRID, _MSC_VER */
140 
141 #if !defined(_MSC_VER) || defined(BUILDING_STARPU)
142 int starpu_pthread_mutex_lock_sched(starpu_pthread_mutex_t *mutex);
143 int starpu_pthread_mutex_unlock_sched(starpu_pthread_mutex_t *mutex);
144 int starpu_pthread_mutex_trylock_sched(starpu_pthread_mutex_t *mutex);
145 void starpu_pthread_mutex_check_sched(starpu_pthread_mutex_t *mutex, char *file, int line);
146 #endif
147 
148 /*
149  * Encapsulation of the pthread_key_* functions.
150  */
151 #ifdef STARPU_SIMGRID
152 
153 typedef int starpu_pthread_key_t;
154 int starpu_pthread_key_create(starpu_pthread_key_t *key, void (*destr_function) (void *));
155 int starpu_pthread_key_delete(starpu_pthread_key_t key);
156 int starpu_pthread_setspecific(starpu_pthread_key_t key, const void *pointer);
157 void *starpu_pthread_getspecific(starpu_pthread_key_t key);
158 
159 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) /* !STARPU_SIMGRID */
160 
161 typedef pthread_key_t starpu_pthread_key_t;
162 
163 #define starpu_pthread_key_create pthread_key_create
164 #define starpu_pthread_key_delete pthread_key_delete
165 #define starpu_pthread_setspecific pthread_setspecific
166 #define starpu_pthread_getspecific pthread_getspecific
167 
168 #endif /* STARPU_SIMGRID, _MSC_VER */
169 
170 /*
171  * Encapsulation of the pthread_cond_* functions.
172  */
173 
174 #ifdef STARPU_SIMGRID
175 
176 typedef xbt_cond_t starpu_pthread_cond_t;
177 typedef int starpu_pthread_condattr_t;
178 #define STARPU_PTHREAD_COND_INITIALIZER NULL
179 
180 int starpu_pthread_cond_init(starpu_pthread_cond_t *cond, starpu_pthread_condattr_t *cond_attr);
181 int starpu_pthread_cond_signal(starpu_pthread_cond_t *cond);
182 int starpu_pthread_cond_broadcast(starpu_pthread_cond_t *cond);
183 int starpu_pthread_cond_wait(starpu_pthread_cond_t *cond, starpu_pthread_mutex_t *mutex);
184 int starpu_pthread_cond_timedwait(starpu_pthread_cond_t *cond, starpu_pthread_mutex_t *mutex, const struct timespec *abstime);
185 int starpu_pthread_cond_destroy(starpu_pthread_cond_t *cond);
186 
187 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) /* !STARPU_SIMGRID */
188 
189 typedef pthread_cond_t starpu_pthread_cond_t;
190 typedef pthread_condattr_t starpu_pthread_condattr_t;
191 #define STARPU_PTHREAD_COND_INITIALIZER PTHREAD_COND_INITIALIZER
192 
193 #define starpu_pthread_cond_init pthread_cond_init
194 #define starpu_pthread_cond_signal pthread_cond_signal
195 #define starpu_pthread_cond_broadcast pthread_cond_broadcast
196 
197 #ifdef STARPU_FXT_LOCK_TRACES
198 int starpu_pthread_cond_wait(starpu_pthread_cond_t *cond, starpu_pthread_mutex_t *mutex);
199 #else
200 #define starpu_pthread_cond_wait pthread_cond_wait
201 #endif
202 
203 #define starpu_pthread_cond_timedwait pthread_cond_timedwait
204 #define starpu_pthread_cond_destroy pthread_cond_destroy
205 
206 #endif /* STARPU_SIMGRID, _MSC_VER */
207 
208 /*
209  * Encapsulation of the pthread_rwlock_* functions.
210  */
211 
212 #ifdef STARPU_SIMGRID
213 
214 typedef xbt_mutex_t starpu_pthread_rwlock_t;
215 typedef int starpu_pthread_rwlockattr_t;
216 
217 int starpu_pthread_rwlock_init(starpu_pthread_rwlock_t *rwlock, const starpu_pthread_rwlockattr_t *attr);
218 int starpu_pthread_rwlock_destroy(starpu_pthread_rwlock_t *rwlock);
219 int starpu_pthread_rwlock_rdlock(starpu_pthread_rwlock_t *rwlock);
220 int starpu_pthread_rwlock_tryrdlock(starpu_pthread_rwlock_t *rwlock);
221 int starpu_pthread_rwlock_wrlock(starpu_pthread_rwlock_t *rwlock);
222 int starpu_pthread_rwlock_trywrlock(starpu_pthread_rwlock_t *rwlock);
223 int starpu_pthread_rwlock_unlock(starpu_pthread_rwlock_t *rwlock);
224 
225 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) /* !STARPU_SIMGRID */
226 
227 typedef pthread_rwlock_t starpu_pthread_rwlock_t;
228 typedef pthread_rwlockattr_t starpu_pthread_rwlockattr_t;
229 
230 #define starpu_pthread_rwlock_init pthread_rwlock_init
231 #define starpu_pthread_rwlock_destroy pthread_rwlock_destroy
232 
233 #ifdef STARPU_FXT_LOCK_TRACES
234 int starpu_pthread_rwlock_rdlock(starpu_pthread_rwlock_t *rwlock);
235 int starpu_pthread_rwlock_tryrdlock(starpu_pthread_rwlock_t *rwlock);
236 int starpu_pthread_rwlock_wrlock(starpu_pthread_rwlock_t *rwlock);
237 int starpu_pthread_rwlock_trywrlock(starpu_pthread_rwlock_t *rwlock);
238 int starpu_pthread_rwlock_unlock(starpu_pthread_rwlock_t *rwlock);
239 #else
240 #define starpu_pthread_rwlock_rdlock pthread_rwlock_rdlock
241 #define starpu_pthread_rwlock_tryrdlock pthread_rwlock_tryrdlock
242 #define starpu_pthread_rwlock_wrlock pthread_rwlock_wrlock
243 #define starpu_pthread_rwlock_trywrlock pthread_rwlock_trywrlock
244 #define starpu_pthread_rwlock_unlock pthread_rwlock_unlock
245 #endif
246 
247 #endif /* STARPU_SIMGRID, _MSC_VER */
248 
249 /*
250  * Encapsulation of the pthread_barrier_* functions.
251  */
252 
253 #if defined(STARPU_SIMGRID) || (!defined(STARPU_HAVE_PTHREAD_BARRIER) && (!defined(_MSC_VER) || defined(BUILDING_STARPU)))
254 
255 #if defined(STARPU_SIMGRID) && (defined(STARPU_SIMGRID_HAVE_XBT_BARRIER_INIT) || defined(xbt_barrier_init))
256 typedef xbt_bar_t starpu_pthread_barrier_t;
257 typedef int starpu_pthread_barrierattr_t;
258 #define STARPU_PTHREAD_BARRIER_SERIAL_THREAD XBT_BARRIER_SERIAL_PROCESS
259 #else
260 typedef struct {
261  starpu_pthread_mutex_t mutex;
262  starpu_pthread_cond_t cond;
263  starpu_pthread_cond_t cond_destroy;
264  unsigned count;
265  unsigned done;
266  unsigned busy;
267 } starpu_pthread_barrier_t;
268 typedef int starpu_pthread_barrierattr_t;
269 #define STARPU_PTHREAD_BARRIER_SERIAL_THREAD -1
270 #endif
271 
272 int starpu_pthread_barrier_init(starpu_pthread_barrier_t *barrier, const starpu_pthread_barrierattr_t *attr, unsigned count);
273 int starpu_pthread_barrier_destroy(starpu_pthread_barrier_t *barrier);
274 int starpu_pthread_barrier_wait(starpu_pthread_barrier_t *barrier);
275 
276 #elif !defined(_MSC_VER) /* STARPU_SIMGRID, !STARPU_HAVE_PTHREAD_BARRIER */
277 
278 typedef pthread_barrier_t starpu_pthread_barrier_t;
279 typedef pthread_barrierattr_t starpu_pthread_barrierattr_t;
280 
281 #define starpu_pthread_barrier_init pthread_barrier_init
282 #define starpu_pthread_barrier_destroy pthread_barrier_destroy
283 
284 #ifdef STARPU_FXT_LOCK_TRACES
285 int starpu_pthread_barrier_wait(starpu_pthread_barrier_t *barrier);
286 #else
287 #define starpu_pthread_barrier_wait pthread_barrier_wait
288 #endif
289 #define STARPU_PTHREAD_BARRIER_SERIAL_THREAD PTHREAD_BARRIER_SERIAL_THREAD
290 
291 #endif /* STARPU_SIMGRID, !STARPU_HAVE_PTHREAD_BARRIER, _MSC_VER */
292 
293 /*
294  * Encapsulation of the pthread_spin_* functions.
295  */
296 
297 #if defined(STARPU_SIMGRID) || (defined(STARPU_LINUX_SYS) && defined(STARPU_HAVE_XCHG)) || !defined(STARPU_HAVE_PTHREAD_SPIN_LOCK)
298 
299 typedef struct
300 {
301 #ifdef STARPU_SIMGRID
302  int taken;
303 #elif defined(STARPU_LINUX_SYS) && defined(STARPU_HAVE_XCHG)
304  unsigned taken STARPU_ATTRIBUTE_ALIGNED(16);
305 #else /* we only have a trivial implementation yet ! */
306  uint32_t taken STARPU_ATTRIBUTE_ALIGNED(16);
307 #endif
309 
315 
316 #elif !defined(_MSC_VER) /* !( defined(STARPU_SIMGRID) || !defined(STARPU_HAVE_PTHREAD_SPIN_LOCK)) */
317 
318 typedef pthread_spinlock_t starpu_pthread_spinlock_t;
319 #define starpu_pthread_spin_init pthread_spin_init
320 #define starpu_pthread_spin_destroy pthread_spin_destroy
321 #define starpu_pthread_spin_lock pthread_spin_lock
322 #define starpu_pthread_spin_trylock pthread_spin_trylock
323 #define starpu_pthread_spin_unlock pthread_spin_unlock
324 
325 #endif /* !( defined(STARPU_SIMGRID) || !defined(STARPU_HAVE_PTHREAD_SPIN_LOCK)) */
326 
327 /*
328  * Other needed pthread definitions
329  */
330 
331 #if defined(_MSC_VER) && !defined(BUILDING_STARPU)
332 typedef void* starpu_pthread_rwlock_t;
333 typedef void* starpu_pthread_mutex_t;
334 typedef void* starpu_pthread_cond_t;
335 typedef void* starpu_pthread_barrier_t;
336 #endif /* _MSC_VER */
337 
338 /*
339  * Simgrid-specific register/wait synchronization
340  *
341  * Producers create a "queue" object, and when they have produced something,
342  * they call either queue_signal or queue_broadcast in order to wake either one
343  * or all consumers waiting on the queue.
344  *
345  * starpu_pthread_queue_init(&global_queue1->queue);
346  * while (1) {
347  * element = compute();
348  * push(element, global_queue1);
349  * starpu_pthread_queue_signal(global_queue1);
350  * }
351  * starpu_pthread_queue_destroy(&global_queue1->queue);
352  *
353  * Consumers create a "wait" object, then queue_register on as many queues they
354  * want. In their consumption loop, they wait_reset, then test for availibility
355  * on all producers, and if none was available, call wait_wait to actually wait
356  * for producers. On termination, consumers have to queue_unregister before
357  * destroying the "wait" object:
358  *
359  * starpu_pthread_wait_t wait;
360  *
361  * starpu_pthread_wait_init(&wait);
362  * starpu_pthread_queue_register(&wait, &global_queue1->queue);
363  * starpu_pthread_queue_register(&wait, &global_queue2->queue);
364  *
365  * while (1) {
366  * int sleep = 1;
367  * starpu_pthread_wait_reset(&wait);
368  * if (global_queue1->navailable)
369  * {
370  * work(global_queue1);
371  * sleep = 0;
372  * }
373  * if (global_queue2->navailable)
374  * {
375  * work(global_queue2);
376  * sleep = 0;
377  * }
378  * if (sleep)
379  * starpu_pthread_wait_wait(&wait);
380  * }
381  * starpu_pthread_queue_unregister(&wait, &global_queue1->queue);
382  * starpu_pthread_queue_unregister(&wait, &global_queue2->queue);
383  * starpu_pthread_wait_destroy(&wait);
384  */
385 
386 #ifdef STARPU_SIMGRID
387 typedef struct
388 {
389  starpu_pthread_mutex_t mutex;
390  starpu_pthread_cond_t cond;
391  unsigned block;
393 
394 typedef struct
395 {
396  starpu_pthread_mutex_t mutex;
397  starpu_pthread_wait_t **queue;
398  unsigned allocqueue;
399  unsigned nqueue;
401 
402 int starpu_pthread_queue_init(starpu_pthread_queue_t *q);
403 int starpu_pthread_queue_signal(starpu_pthread_queue_t *q);
404 int starpu_pthread_queue_broadcast(starpu_pthread_queue_t *q);
405 int starpu_pthread_queue_destroy(starpu_pthread_queue_t *q);
406 
407 int starpu_pthread_wait_init(starpu_pthread_wait_t *w);
408 int starpu_pthread_queue_register(starpu_pthread_wait_t *w, starpu_pthread_queue_t *q);
409 int starpu_pthread_queue_unregister(starpu_pthread_wait_t *w, starpu_pthread_queue_t *q);
410 int starpu_pthread_wait_reset(starpu_pthread_wait_t *w);
411 int starpu_pthread_wait_wait(starpu_pthread_wait_t *w);
412 int starpu_pthread_wait_timedwait(starpu_pthread_wait_t *w, const struct timespec *abstime);
413 int starpu_pthread_wait_destroy(starpu_pthread_wait_t *w);
414 #endif
415 
416 /*
417  * Encapsulation of the semaphore functions.
418  */
419 
420 #ifdef STARPU_SIMGRID
421 
422 typedef msg_sem_t starpu_sem_t;
423 int starpu_sem_destroy(starpu_sem_t *);
424 int starpu_sem_getvalue(starpu_sem_t *, int *);
425 int starpu_sem_init(starpu_sem_t *, int, unsigned);
426 int starpu_sem_post(starpu_sem_t *);
427 int starpu_sem_trywait(starpu_sem_t *);
428 int starpu_sem_wait(starpu_sem_t *);
429 
430 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) /* !STARPU_SIMGRID */
431 
432 typedef sem_t starpu_sem_t;
433 #define starpu_sem_destroy sem_destroy
434 #define starpu_sem_getvalue sem_getvalue
435 #define starpu_sem_init sem_init
436 #define starpu_sem_post sem_post
437 int starpu_sem_trywait(starpu_sem_t *);
438 int starpu_sem_wait(starpu_sem_t *);
439 
440 #endif
441 
442 #ifdef __cplusplus
443 }
444 #endif
445 
446 #endif /* __STARPU_THREAD_H__ */
int starpu_pthread_spin_trylock(starpu_pthread_spinlock_t *lock)
int starpu_pthread_cond_wait(starpu_pthread_cond_t *cond, starpu_pthread_mutex_t *mutex)
int starpu_pthread_barrier_wait(starpu_pthread_barrier_t *barrier)
void * starpu_pthread_getspecific(starpu_pthread_key_t key)
#define STARPU_ATTRIBUTE_ALIGNED(size)
Definition: starpu_util.h:141
int starpu_pthread_mutexattr_destroy(starpu_pthread_mutexattr_t *attr)
int starpu_pthread_spin_unlock(starpu_pthread_spinlock_t *lock)
int starpu_pthread_mutex_unlock(starpu_pthread_mutex_t *mutex)
int starpu_pthread_spin_lock(starpu_pthread_spinlock_t *lock)
int starpu_pthread_barrier_destroy(starpu_pthread_barrier_t *barrier)
int starpu_pthread_attr_destroy(starpu_pthread_attr_t *attr)
int starpu_pthread_mutexattr_init(starpu_pthread_mutexattr_t *attr)
int starpu_pthread_setspecific(starpu_pthread_key_t key, const void *pointer)
int starpu_pthread_exit(void *retval) STARPU_ATTRIBUTE_NORETURN
int starpu_pthread_spin_init(starpu_pthread_spinlock_t *lock, int pshared)
int starpu_pthread_barrier_init(starpu_pthread_barrier_t *barrier, const starpu_pthread_barrierattr_t *attr, unsigned count)
int starpu_pthread_cond_destroy(starpu_pthread_cond_t *cond)
int starpu_pthread_mutex_destroy(starpu_pthread_mutex_t *mutex)
int starpu_pthread_cond_broadcast(starpu_pthread_cond_t *cond)
int starpu_pthread_mutexattr_gettype(const starpu_pthread_mutexattr_t *attr, int *type)
int starpu_pthread_cond_timedwait(starpu_pthread_cond_t *cond, starpu_pthread_mutex_t *mutex, const struct timespec *abstime)
Definition: starpu_thread.h:299
#define STARPU_ATTRIBUTE_NORETURN
Definition: starpu_util.h:96
Definition: starpu_thread.h:387
int starpu_pthread_rwlock_rdlock(starpu_pthread_rwlock_t *rwlock)
int starpu_pthread_rwlock_unlock(starpu_pthread_rwlock_t *rwlock)
Definition: starpu_thread.h:260
int starpu_pthread_rwlock_wrlock(starpu_pthread_rwlock_t *rwlock)
int starpu_pthread_mutexattr_settype(starpu_pthread_mutexattr_t *attr, int type)
Definition: starpu_thread.h:394
int starpu_pthread_rwlock_init(starpu_pthread_rwlock_t *rwlock, const starpu_pthread_rwlockattr_t *attr)
int starpu_pthread_join(starpu_pthread_t thread, void **retval)
int starpu_pthread_mutex_init(starpu_pthread_mutex_t *mutex, const starpu_pthread_mutexattr_t *mutexattr)
int starpu_pthread_key_delete(starpu_pthread_key_t key)
int starpu_pthread_rwlock_destroy(starpu_pthread_rwlock_t *rwlock)
int starpu_pthread_cond_init(starpu_pthread_cond_t *cond, starpu_pthread_condattr_t *cond_attr)
int starpu_pthread_rwlock_trywrlock(starpu_pthread_rwlock_t *rwlock)
int starpu_pthread_create(starpu_pthread_t *thread, const starpu_pthread_attr_t *attr, void *(*start_routine)(void *), void *arg)
int starpu_pthread_attr_init(starpu_pthread_attr_t *attr)
int starpu_pthread_attr_setdetachstate(starpu_pthread_attr_t *attr, int detachstate)
int starpu_pthread_rwlock_tryrdlock(starpu_pthread_rwlock_t *rwlock)
int starpu_pthread_mutex_lock(starpu_pthread_mutex_t *mutex)
int starpu_pthread_spin_destroy(starpu_pthread_spinlock_t *lock)
int starpu_pthread_cond_signal(starpu_pthread_cond_t *cond)
int starpu_pthread_mutex_trylock(starpu_pthread_mutex_t *mutex)
int starpu_pthread_key_create(starpu_pthread_key_t *key, void(*destr_function)(void *))