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
|
// Create threads in such a way that there is a realistic chance that the
// parent thread finishes before the created thread finishes.
#include <assert.h>
#include <limits.h> /* PTHREAD_STACK_MIN */
#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
static pthread_t s_thread[1000];
static int s_arg[1000];
static void* thread_func(void* p)
{
int thread_count = *(int*)(p);
pthread_attr_t attr;
if (thread_count > 0)
{
thread_count--;
// std::cout << "create " << thread_count << std::endl;
s_arg[thread_count] = thread_count;
pthread_attr_init(&attr);
pthread_attr_setstacksize(&attr, PTHREAD_STACK_MIN);
pthread_create(&s_thread[thread_count], &attr, thread_func,
&s_arg[thread_count]);
pthread_attr_destroy(&attr);
#if 0
std::cout << "created " << thread_count << "(" << s_thread[thread_count]
<< ")" << std::endl;
#endif
}
return 0;
}
int main(int argc, char** argv)
{
pthread_attr_t attr;
unsigned thread_count;
int i;
thread_count = argc > 1 ? atoi(argv[1]) : 50;
assert(thread_count <= sizeof(s_thread) / sizeof(s_thread[0]));
assert(thread_count >= 1);
thread_count--;
// std::cout << "create " << thread_count << std::endl;
pthread_attr_init(&attr);
pthread_attr_setstacksize(&attr, PTHREAD_STACK_MIN);
pthread_create(&s_thread[thread_count], &attr, thread_func,
&thread_count);
pthread_attr_destroy(&attr);
#if 0
std::cout << "created " << thread_count << "(" << s_thread[thread_count]
<< ")" << std::endl;
#endif
for (i = thread_count; i >= 0; i--)
{
// std::cout << "join " << i << "(" << s_thread[i] << ")" << std::endl;
pthread_join(s_thread[i], 0);
}
return 0;
}
|
