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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
#include <thread.h>
#include <synch.h>
#include <math.h>
#include <sys/times.h>
#include <limits.h>
mutex_t test_lock;
mutex_t count_lock;
sema_t gosem,retsem;
int count=0;
float sinx=0.0;
dofunc(n)
int n;
{ int i;
thread_t self;
self=thr_self();
for (i=0; i<n; i++) {
mutex_lock(&count_lock);
count++; sinx += sin(i % 6);
mutex_unlock(&count_lock);
/* thr_yield(); */
}
printf("id=%d count=%d sinx=%f\n", self, count, sinx);
}
semtest(n)
int n;
{ register int i;
for (i=0; i<n; i++) {
sema_wait(&gosem);
sema_post(&retsem);}
printf("sematest exit\n");}
float ustime(t1, t2) /*returns time in milli second*/
struct tms *t1, *t2;
{ return((1000.0/CLK_TCK) *
((t2->tms_utime-t1->tms_utime) + (t2->tms_stime-t1->tms_stime)));}
main(argc,argv)
int argc;
char *argv[];
{
thread_t thrid[10001];
int stat, *statp, stat2, s=1, exitstat, N;
struct tms t1,t2,t3,t4,t5,t6;
register int i;
int concurrency;
stat=thr_self();
stat2=thr_min_stack();
if (argc>=2) sscanf(argv[1],"%d", &concurrency);
else concurrency=4;
if (argc>=3) sscanf(argv[2], "%d", &N);
else N=1000;
thr_setconcurrency(concurrency);
printf("self=%d minstack=%x concurrency=%d CLK_TCK=%d\n\n",
stat, stat2, thr_getconcurrency(), CLK_TCK);
times(&t1);
for (i=0; i<N; i++) {
stat=thr_create(0,0,thr_exit,&exitstat,THR_BOUND,&thrid[i]);
if (i % 100 ==0) {printf("%d stat=%d\n", i, stat);}}
times(&t2);
printf("creation time=%f max_thrid=%d\n", ustime(&t1, &t2)/(float)N,thrid[N-1]);
times(&t2);
for(i=0; i<N; i++) { thr_join(thrid[i], 0, 0);}
times(&t3);
printf("join time=%f\n", ustime(&t2, &t3)/(float)N);
sema_init(&gosem, 0, USYNC_THREAD, 0);
sema_init(&retsem, 0, USYNC_THREAD, 0);
stat=thr_create(0,0,semtest,N,0,&thrid[0]);
times(&t3);
for (i=0; i<N; i++) {
sema_post(&gosem);
sema_wait(&retsem);}
times(&t4);
printf("sema switch time=%f\n", ustime(&t3, &t4)/(float)N);
for (i=0; i<N; i++) {
mutex_lock(&test_lock);
mutex_unlock(&test_lock);
mutex_lock(&test_lock);
mutex_unlock(&test_lock);
mutex_lock(&test_lock);
mutex_unlock(&test_lock);
mutex_lock(&test_lock);
mutex_unlock(&test_lock);
mutex_lock(&test_lock);
mutex_unlock(&test_lock);}
times(&t5);
printf("mutex_lock & unlock time=%f\n", ustime(&t4, &t5)/((float)N*5.0));
for (s=0; s<5; s++) {
stat=thr_create(0,0, dofunc, 10000, 0, &thrid[s]);
/* printf("stat=%x thrid=%x\n", stat, thrid[s]); */
if (stat!=0) exit(1);}
statp=&stat;
for (s=0; s<5; s++)
stat2=thr_join(thrid[s], 0, &statp);
printf("stat2=%x stat=%x concurrency=%d\n", stat2, stat, thr_getconcurrency());}
|
