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
|
/*
* Test program that triggers pthread_barrier_wait() where each
* pthread_barrier_wait() call is invoked by another thread. This is the only
* test program that triggers the code guarded by if (q->thread_finished) in
* DRD_(barrier_pre_wait)().
*/
#define _GNU_SOURCE
#include <assert.h>
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
static pthread_barrier_t* s_barrier;
static void* thread(void* arg)
{
write(STDOUT_FILENO, ".", 1);
pthread_barrier_wait(s_barrier);
return NULL;
}
int main(int argc, char** argv)
{
pthread_t *tid;
int barriers = argc > 1 ? atoi(argv[1]) : 20;
int barrier_participants = 2;
int thread_count = barriers * barrier_participants;
int res, i;
s_barrier = malloc(sizeof(*s_barrier));
res = pthread_barrier_init(s_barrier, NULL, barrier_participants);
assert(res == 0);
tid = malloc(thread_count * sizeof(*tid));
assert(tid);
for (i = 0; i < thread_count; i++) {
res = pthread_create(&tid[i], NULL, thread, NULL);
assert(res == 0);
}
for (i = 0; i < thread_count; i++) {
res = pthread_join(tid[i], NULL);
assert(res == 0);
}
free(tid);
res = pthread_barrier_destroy(s_barrier);
assert(res == 0);
free(s_barrier);
s_barrier = NULL;
write(STDOUT_FILENO, "\n", 1);
fprintf(stderr, "Done.\n");
return 0;
}
|
