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_ACTOR_H
34 #include <simgrid/actor.h>
35 #endif
36 #ifdef STARPU_HAVE_SIMGRID_SEMAPHORE_H
37 #include <simgrid/semaphore.h>
38 #endif
39 #ifdef STARPU_HAVE_SIMGRID_MUTEX_H
40 #include <simgrid/mutex.h>
41 #endif
42 #ifdef STARPU_HAVE_SIMGRID_COND_H
43 #include <simgrid/cond.h>
44 #endif
45 #ifdef STARPU_HAVE_SIMGRID_BARRIER_H
46 #include <simgrid/barrier.h>
47 #endif
48 #ifdef STARPU_HAVE_SIMGRID_MSG_H
49 #include <simgrid/msg.h>
50 #else
51 #include <msg/msg.h>
52 #endif
53 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU)
54 #include <pthread.h>
55 #include <semaphore.h>
56 #endif
57 #include <stdint.h>
58 
59 #ifdef __cplusplus
60 extern "C"
61 {
62 #endif
63 
64 /*
65  * Encapsulation of the pthread_create function.
66  */
67 
68 #ifdef STARPU_SIMGRID
69 
70 #ifdef STARPU_HAVE_SIMGRID_ACTOR_H
71 typedef sg_actor_t starpu_pthread_t;
72 #else
73 typedef msg_process_t starpu_pthread_t;
74 #endif
75 typedef int starpu_pthread_attr_t;
76 
77 #ifdef STARPU_HAVE_SIMGRID_ACTOR_H
78 typedef sg_host_t starpu_sg_host_t;
79 #else
80 typedef msg_host_t starpu_sg_host_t;
81 #endif
82 int starpu_pthread_equal(starpu_pthread_t t1, starpu_pthread_t t2);
83 starpu_pthread_t starpu_pthread_self(void);
84 int starpu_pthread_create_on(char *name, starpu_pthread_t *thread, const starpu_pthread_attr_t *attr, void *(*start_routine) (void *), void *arg, starpu_sg_host_t host);
85 int starpu_pthread_create(starpu_pthread_t *thread, const starpu_pthread_attr_t *attr, void *(*start_routine) (void *), void *arg);
86 int starpu_pthread_join(starpu_pthread_t thread, void **retval);
88 int starpu_pthread_attr_init(starpu_pthread_attr_t *attr);
89 int starpu_pthread_attr_destroy(starpu_pthread_attr_t *attr);
90 int starpu_pthread_attr_setdetachstate(starpu_pthread_attr_t *attr, int detachstate);
91 
92 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) /* STARPU_SIMGRID */
93 
94 typedef pthread_t starpu_pthread_t;
95 typedef pthread_attr_t starpu_pthread_attr_t;
96 
97 #define starpu_pthread_equal pthread_equal
98 #define starpu_pthread_self pthread_self
99 #define starpu_pthread_create pthread_create
100 #define starpu_pthread_create_on(name, thread, attr, routine, arg, where) starpu_pthread_create(thread, attr, routine, arg)
101 #define starpu_pthread_join pthread_join
102 #define starpu_pthread_exit pthread_exit
103 #define starpu_pthread_attr_init pthread_attr_init
104 #define starpu_pthread_attr_destroy pthread_attr_destroy
105 #define starpu_pthread_attr_setdetachstate pthread_attr_setdetachstate
106 
107 #endif /* STARPU_SIMGRID, _MSC_VER */
108 
109 #ifdef STARPU_HAVE_PTHREAD_SETNAME_NP
110 #ifdef STARPU_HAVE_DARWIN
111 #define starpu_pthread_setname(name) pthread_setname_np(name)
112 #else
113 #define starpu_pthread_setname(name) pthread_setname_np(pthread_self(), name)
114 #endif
115 #else
116 #define starpu_pthread_setname(name)
117 #endif
118 
119 /*
120  * Encapsulation of the pthread_mutex_* functions.
121  */
122 
123 #ifdef STARPU_SIMGRID
124 #ifdef STARPU_HAVE_SIMGRID_MUTEX_H
125 typedef sg_mutex_t starpu_pthread_mutex_t;
126 #else
127 typedef xbt_mutex_t starpu_pthread_mutex_t;
128 #endif
129 typedef int starpu_pthread_mutexattr_t;
130 
131 #define STARPU_PTHREAD_MUTEX_INITIALIZER NULL
132 
133 int starpu_pthread_mutex_init(starpu_pthread_mutex_t *mutex, const starpu_pthread_mutexattr_t *mutexattr);
134 int starpu_pthread_mutex_destroy(starpu_pthread_mutex_t *mutex);
135 int starpu_pthread_mutex_lock(starpu_pthread_mutex_t *mutex);
136 int starpu_pthread_mutex_unlock(starpu_pthread_mutex_t *mutex);
137 int starpu_pthread_mutex_trylock(starpu_pthread_mutex_t *mutex);
138 int starpu_pthread_mutexattr_gettype(const starpu_pthread_mutexattr_t *attr, int *type);
139 int starpu_pthread_mutexattr_settype(starpu_pthread_mutexattr_t *attr, int type);
140 int starpu_pthread_mutexattr_destroy(starpu_pthread_mutexattr_t *attr);
141 int starpu_pthread_mutexattr_init(starpu_pthread_mutexattr_t *attr);
142 
143 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) /* !STARPU_SIMGRID */
144 
145 typedef pthread_mutex_t starpu_pthread_mutex_t;
146 typedef pthread_mutexattr_t starpu_pthread_mutexattr_t;
147 
148 #define starpu_pthread_mutex_init pthread_mutex_init
149 #define starpu_pthread_mutex_destroy pthread_mutex_destroy
150 #define starpu_pthread_mutexattr_gettype pthread_mutexattr_gettype
151 #define starpu_pthread_mutexattr_settype pthread_mutexattr_settype
152 #define starpu_pthread_mutexattr_destroy pthread_mutexattr_destroy
153 #define starpu_pthread_mutexattr_init pthread_mutexattr_init
154 
155 #ifdef STARPU_FXT_LOCK_TRACES
156 int starpu_pthread_mutex_lock(starpu_pthread_mutex_t *mutex);
157 int starpu_pthread_mutex_unlock(starpu_pthread_mutex_t *mutex);
158 int starpu_pthread_mutex_trylock(starpu_pthread_mutex_t *mutex);
159 #else
160 #define starpu_pthread_mutex_lock pthread_mutex_lock
161 #define starpu_pthread_mutex_unlock pthread_mutex_unlock
162 #define starpu_pthread_mutex_trylock pthread_mutex_trylock
163 #endif
164 
165 #define STARPU_PTHREAD_MUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER
166 
167 #endif /* STARPU_SIMGRID, _MSC_VER */
168 
169 #if !defined(_MSC_VER) || defined(BUILDING_STARPU)
170 int starpu_pthread_mutex_lock_sched(starpu_pthread_mutex_t *mutex);
171 int starpu_pthread_mutex_unlock_sched(starpu_pthread_mutex_t *mutex);
172 int starpu_pthread_mutex_trylock_sched(starpu_pthread_mutex_t *mutex);
173 void starpu_pthread_mutex_check_sched(starpu_pthread_mutex_t *mutex, char *file, int line);
174 #endif
175 
176 /*
177  * Encapsulation of the pthread_key_* functions.
178  */
179 #ifdef STARPU_SIMGRID
180 
181 typedef int starpu_pthread_key_t;
182 int starpu_pthread_key_create(starpu_pthread_key_t *key, void (*destr_function) (void *));
183 int starpu_pthread_key_delete(starpu_pthread_key_t key);
184 int starpu_pthread_setspecific(starpu_pthread_key_t key, const void *pointer);
185 void *starpu_pthread_getspecific(starpu_pthread_key_t key);
186 
187 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) /* !STARPU_SIMGRID */
188 
189 typedef pthread_key_t starpu_pthread_key_t;
190 
191 #define starpu_pthread_key_create pthread_key_create
192 #define starpu_pthread_key_delete pthread_key_delete
193 #define starpu_pthread_setspecific pthread_setspecific
194 #define starpu_pthread_getspecific pthread_getspecific
195 
196 #endif /* STARPU_SIMGRID, _MSC_VER */
197 
198 /*
199  * Encapsulation of the pthread_cond_* functions.
200  */
201 
202 #ifdef STARPU_SIMGRID
203 
204 #ifdef STARPU_HAVE_SIMGRID_COND_H
205 typedef sg_cond_t starpu_pthread_cond_t;
206 #else
207 typedef xbt_cond_t starpu_pthread_cond_t;
208 #endif
209 typedef int starpu_pthread_condattr_t;
210 #define STARPU_PTHREAD_COND_INITIALIZER NULL
211 
212 int starpu_pthread_cond_init(starpu_pthread_cond_t *cond, starpu_pthread_condattr_t *cond_attr);
213 int starpu_pthread_cond_signal(starpu_pthread_cond_t *cond);
214 int starpu_pthread_cond_broadcast(starpu_pthread_cond_t *cond);
215 int starpu_pthread_cond_wait(starpu_pthread_cond_t *cond, starpu_pthread_mutex_t *mutex);
216 int starpu_pthread_cond_timedwait(starpu_pthread_cond_t *cond, starpu_pthread_mutex_t *mutex, const struct timespec *abstime);
217 int starpu_pthread_cond_destroy(starpu_pthread_cond_t *cond);
218 
219 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) /* !STARPU_SIMGRID */
220 
221 typedef pthread_cond_t starpu_pthread_cond_t;
222 typedef pthread_condattr_t starpu_pthread_condattr_t;
223 #define STARPU_PTHREAD_COND_INITIALIZER PTHREAD_COND_INITIALIZER
224 
225 #define starpu_pthread_cond_init pthread_cond_init
226 #define starpu_pthread_cond_signal pthread_cond_signal
227 #define starpu_pthread_cond_broadcast pthread_cond_broadcast
228 
229 #ifdef STARPU_FXT_LOCK_TRACES
230 int starpu_pthread_cond_wait(starpu_pthread_cond_t *cond, starpu_pthread_mutex_t *mutex);
231 #else
232 #define starpu_pthread_cond_wait pthread_cond_wait
233 #endif
234 
235 #define starpu_pthread_cond_timedwait pthread_cond_timedwait
236 #define starpu_pthread_cond_destroy pthread_cond_destroy
237 
238 #endif /* STARPU_SIMGRID, _MSC_VER */
239 
240 /*
241  * Encapsulation of the pthread_rwlock_* functions.
242  */
243 
244 #ifdef STARPU_SIMGRID
245 
246 #ifdef STARPU_HAVE_SIMGRID_MUTEX_H
247 typedef sg_mutex_t starpu_pthread_rwlock_t;
248 #else
249 typedef xbt_mutex_t starpu_pthread_rwlock_t;
250 #endif
251 typedef int starpu_pthread_rwlockattr_t;
252 
253 int starpu_pthread_rwlock_init(starpu_pthread_rwlock_t *rwlock, const starpu_pthread_rwlockattr_t *attr);
254 int starpu_pthread_rwlock_destroy(starpu_pthread_rwlock_t *rwlock);
255 int starpu_pthread_rwlock_rdlock(starpu_pthread_rwlock_t *rwlock);
256 int starpu_pthread_rwlock_tryrdlock(starpu_pthread_rwlock_t *rwlock);
257 int starpu_pthread_rwlock_wrlock(starpu_pthread_rwlock_t *rwlock);
258 int starpu_pthread_rwlock_trywrlock(starpu_pthread_rwlock_t *rwlock);
259 int starpu_pthread_rwlock_unlock(starpu_pthread_rwlock_t *rwlock);
260 
261 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) /* !STARPU_SIMGRID */
262 
263 typedef pthread_rwlock_t starpu_pthread_rwlock_t;
264 typedef pthread_rwlockattr_t starpu_pthread_rwlockattr_t;
265 
266 #define starpu_pthread_rwlock_init pthread_rwlock_init
267 #define starpu_pthread_rwlock_destroy pthread_rwlock_destroy
268 
269 #ifdef STARPU_FXT_LOCK_TRACES
270 int starpu_pthread_rwlock_rdlock(starpu_pthread_rwlock_t *rwlock);
271 int starpu_pthread_rwlock_tryrdlock(starpu_pthread_rwlock_t *rwlock);
272 int starpu_pthread_rwlock_wrlock(starpu_pthread_rwlock_t *rwlock);
273 int starpu_pthread_rwlock_trywrlock(starpu_pthread_rwlock_t *rwlock);
274 int starpu_pthread_rwlock_unlock(starpu_pthread_rwlock_t *rwlock);
275 #else
276 #define starpu_pthread_rwlock_rdlock pthread_rwlock_rdlock
277 #define starpu_pthread_rwlock_tryrdlock pthread_rwlock_tryrdlock
278 #define starpu_pthread_rwlock_wrlock pthread_rwlock_wrlock
279 #define starpu_pthread_rwlock_trywrlock pthread_rwlock_trywrlock
280 #define starpu_pthread_rwlock_unlock pthread_rwlock_unlock
281 #endif
282 
283 #endif /* STARPU_SIMGRID, _MSC_VER */
284 
285 /*
286  * Encapsulation of the pthread_barrier_* functions.
287  */
288 
289 #if defined(STARPU_SIMGRID) || (!defined(STARPU_HAVE_PTHREAD_BARRIER) && (!defined(_MSC_VER) || defined(BUILDING_STARPU)))
290 
291 #if defined(STARPU_SIMGRID) && (defined(STARPU_HAVE_SIMGRID_BARRIER_H) || defined(STARPU_SIMGRID_HAVE_XBT_BARRIER_INIT) || defined(xbt_barrier_init))
292 #ifdef STARPU_HAVE_SIMGRID_BARRIER_H
293 typedef sg_bar_t starpu_pthread_barrier_t;
294 #else
295 typedef xbt_bar_t starpu_pthread_barrier_t;
296 #endif
297 typedef int starpu_pthread_barrierattr_t;
298 #define STARPU_PTHREAD_BARRIER_SERIAL_THREAD -1
299 #else
300 typedef struct {
301  starpu_pthread_mutex_t mutex;
302  starpu_pthread_cond_t cond;
303  starpu_pthread_cond_t cond_destroy;
304  unsigned count;
305  unsigned done;
306  unsigned busy;
307 } starpu_pthread_barrier_t;
308 typedef int starpu_pthread_barrierattr_t;
309 #define STARPU_PTHREAD_BARRIER_SERIAL_THREAD -1
310 #endif
311 
312 int starpu_pthread_barrier_init(starpu_pthread_barrier_t *barrier, const starpu_pthread_barrierattr_t *attr, unsigned count);
313 int starpu_pthread_barrier_destroy(starpu_pthread_barrier_t *barrier);
314 int starpu_pthread_barrier_wait(starpu_pthread_barrier_t *barrier);
315 
316 #elif !defined(_MSC_VER) /* STARPU_SIMGRID, !STARPU_HAVE_PTHREAD_BARRIER */
317 
318 typedef pthread_barrier_t starpu_pthread_barrier_t;
319 typedef pthread_barrierattr_t starpu_pthread_barrierattr_t;
320 
321 #define starpu_pthread_barrier_init pthread_barrier_init
322 #define starpu_pthread_barrier_destroy pthread_barrier_destroy
323 
324 #ifdef STARPU_FXT_LOCK_TRACES
325 int starpu_pthread_barrier_wait(starpu_pthread_barrier_t *barrier);
326 #else
327 #define starpu_pthread_barrier_wait pthread_barrier_wait
328 #endif
329 #define STARPU_PTHREAD_BARRIER_SERIAL_THREAD PTHREAD_BARRIER_SERIAL_THREAD
330 
331 #endif /* STARPU_SIMGRID, !STARPU_HAVE_PTHREAD_BARRIER, _MSC_VER */
332 
333 /*
334  * Encapsulation of the pthread_spin_* functions.
335  */
336 
337 #if defined(STARPU_SIMGRID) || (defined(STARPU_LINUX_SYS) && defined(STARPU_HAVE_XCHG)) || !defined(STARPU_HAVE_PTHREAD_SPIN_LOCK)
338 
339 typedef struct
340 {
341 #ifdef STARPU_SIMGRID
342  int taken;
343 #elif defined(STARPU_LINUX_SYS) && defined(STARPU_HAVE_XCHG)
344  unsigned taken STARPU_ATTRIBUTE_ALIGNED(16);
345 #else /* we only have a trivial implementation yet ! */
346  uint32_t taken STARPU_ATTRIBUTE_ALIGNED(16);
347 #endif
349 
355 
356 #elif !defined(_MSC_VER) /* !( defined(STARPU_SIMGRID) || !defined(STARPU_HAVE_PTHREAD_SPIN_LOCK)) */
357 
358 typedef pthread_spinlock_t starpu_pthread_spinlock_t;
359 #define starpu_pthread_spin_init pthread_spin_init
360 #define starpu_pthread_spin_destroy pthread_spin_destroy
361 #define starpu_pthread_spin_lock pthread_spin_lock
362 #define starpu_pthread_spin_trylock pthread_spin_trylock
363 #define starpu_pthread_spin_unlock pthread_spin_unlock
364 
365 #endif /* !( defined(STARPU_SIMGRID) || !defined(STARPU_HAVE_PTHREAD_SPIN_LOCK)) */
366 
367 /*
368  * Other needed pthread definitions
369  */
370 
371 #if defined(_MSC_VER) && !defined(BUILDING_STARPU)
372 typedef void* starpu_pthread_rwlock_t;
373 typedef void* starpu_pthread_mutex_t;
374 typedef void* starpu_pthread_cond_t;
375 typedef void* starpu_pthread_barrier_t;
376 #endif /* _MSC_VER */
377 
378 /*
379  * Simgrid-specific register/wait synchronization
380  *
381  * Producers create a "queue" object, and when they have produced something,
382  * they call either queue_signal or queue_broadcast in order to wake either one
383  * or all consumers waiting on the queue.
384  *
385  * starpu_pthread_queue_init(&global_queue1->queue);
386  * while (1) {
387  * element = compute();
388  * push(element, global_queue1);
389  * starpu_pthread_queue_signal(global_queue1);
390  * }
391  * starpu_pthread_queue_destroy(&global_queue1->queue);
392  *
393  * Consumers create a "wait" object, then queue_register on as many queues they
394  * want. In their consumption loop, they wait_reset, then test for availibility
395  * on all producers, and if none was available, call wait_wait to actually wait
396  * for producers. On termination, consumers have to queue_unregister before
397  * destroying the "wait" object:
398  *
399  * starpu_pthread_wait_t wait;
400  *
401  * starpu_pthread_wait_init(&wait);
402  * starpu_pthread_queue_register(&wait, &global_queue1->queue);
403  * starpu_pthread_queue_register(&wait, &global_queue2->queue);
404  *
405  * while (1) {
406  * int sleep = 1;
407  * starpu_pthread_wait_reset(&wait);
408  * if (global_queue1->navailable)
409  * {
410  * work(global_queue1);
411  * sleep = 0;
412  * }
413  * if (global_queue2->navailable)
414  * {
415  * work(global_queue2);
416  * sleep = 0;
417  * }
418  * if (sleep)
419  * starpu_pthread_wait_wait(&wait);
420  * }
421  * starpu_pthread_queue_unregister(&wait, &global_queue1->queue);
422  * starpu_pthread_queue_unregister(&wait, &global_queue2->queue);
423  * starpu_pthread_wait_destroy(&wait);
424  */
425 
426 #ifdef STARPU_SIMGRID
427 typedef struct
428 {
429  starpu_pthread_mutex_t mutex;
430  starpu_pthread_cond_t cond;
431  unsigned block;
433 
434 typedef struct
435 {
436  starpu_pthread_mutex_t mutex;
437  starpu_pthread_wait_t **queue;
438  unsigned allocqueue;
439  unsigned nqueue;
441 
442 int starpu_pthread_queue_init(starpu_pthread_queue_t *q);
443 int starpu_pthread_queue_signal(starpu_pthread_queue_t *q);
444 int starpu_pthread_queue_broadcast(starpu_pthread_queue_t *q);
445 int starpu_pthread_queue_destroy(starpu_pthread_queue_t *q);
446 
447 int starpu_pthread_wait_init(starpu_pthread_wait_t *w);
448 int starpu_pthread_queue_register(starpu_pthread_wait_t *w, starpu_pthread_queue_t *q);
449 int starpu_pthread_queue_unregister(starpu_pthread_wait_t *w, starpu_pthread_queue_t *q);
450 int starpu_pthread_wait_reset(starpu_pthread_wait_t *w);
451 int starpu_pthread_wait_wait(starpu_pthread_wait_t *w);
452 int starpu_pthread_wait_timedwait(starpu_pthread_wait_t *w, const struct timespec *abstime);
453 int starpu_pthread_wait_destroy(starpu_pthread_wait_t *w);
454 #endif
455 
456 /*
457  * Encapsulation of the semaphore functions.
458  */
459 
460 #ifdef STARPU_SIMGRID
461 
462 #ifdef STARPU_HAVE_SIMGRID_SEMAPHORE_H
463 typedef sg_sem_t starpu_sem_t;
464 #else
465 typedef msg_sem_t starpu_sem_t;
466 #endif
467 int starpu_sem_destroy(starpu_sem_t *);
468 int starpu_sem_getvalue(starpu_sem_t *, int *);
469 int starpu_sem_init(starpu_sem_t *, int, unsigned);
470 int starpu_sem_post(starpu_sem_t *);
471 int starpu_sem_trywait(starpu_sem_t *);
472 int starpu_sem_wait(starpu_sem_t *);
473 
474 #elif !defined(_MSC_VER) || defined(BUILDING_STARPU) /* !STARPU_SIMGRID */
475 
476 typedef sem_t starpu_sem_t;
477 #define starpu_sem_destroy sem_destroy
478 #define starpu_sem_getvalue sem_getvalue
479 #define starpu_sem_init sem_init
480 #define starpu_sem_post sem_post
481 int starpu_sem_trywait(starpu_sem_t *);
482 int starpu_sem_wait(starpu_sem_t *);
483 
484 #endif
485 
486 #ifdef __cplusplus
487 }
488 #endif
489 
490 #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:339
#define STARPU_ATTRIBUTE_NORETURN
Definition: starpu_util.h:96
Definition: starpu_thread.h:427
int starpu_pthread_rwlock_rdlock(starpu_pthread_rwlock_t *rwlock)
int starpu_pthread_rwlock_unlock(starpu_pthread_rwlock_t *rwlock)
Definition: starpu_thread.h:300
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:434
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 *))