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