threadpool/threads.h at master · pminkov/threadpool · GitHub

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
#ifndef __MYTHREADS_h__
#define __MYTHREADS_h__

#include <pthread.h>
#include <assert.h>
#include <sched.h>
#include <stdio.h>

void
Pthread_cond_init(pthread_cond_t *c) {
  int rc = pthread_cond_init(c, NULL);
  assert(rc == 0);
}

void
Pthread_mutex_init(pthread_mutex_t *m) {
  int rc = pthread_mutex_init(m, NULL);
  assert(rc == 0);
}

void
Pthread_mutex_lock(pthread_mutex_t *m)
{
    int rc = pthread_mutex_lock(m);
    assert(rc == 0);
}

void
Pthread_mutex_unlock(pthread_mutex_t *m)
{
    int rc = pthread_mutex_unlock(m);
    assert(rc == 0);
}

void
Pthread_create(pthread_t *thread, const pthread_attr_t *attr,
	       void *(*start_routine)(void*), void *arg)
{
    int rc = pthread_create(thread, attr, start_routine, arg);
    assert(rc == 0);
}

void
Pthread_join(pthread_t thread, void **value_ptr)
{
    int rc = pthread_join(thread, value_ptr);
    assert(rc == 0);
}

void
Pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex) {
  int rc = pthread_cond_wait(cond, mutex);
  assert(rc == 0);
}

void
Pthread_detach(pthread_t thread) {
  int rc = pthread_detach(thread);
  assert(rc == 0);
}


void
Pthread_cond_signal(pthread_cond_t *cond) {
  int rc = pthread_cond_signal(cond);
  assert(rc == 0);
}

void
Pthread_cond_broadcast(pthread_cond_t *cond) {
  int rc = pthread_cond_broadcast(cond);
  assert(rc == 0);
}


#endif // __MYTHREADS_h__