root / Pi / C / Pthreads / PiMP_orig1.c @ 196
Historique | Voir | Annoter | Télécharger (2,4 ko)
1 | 7 | equemene | /******************************************************************************
|
---|---|---|---|
2 | 7 | equemene | * FILE: hello.c
|
3 | 7 | equemene | * DESCRIPTION:
|
4 | 7 | equemene | * A "hello world" Pthreads program. Demonstrates thread creation and
|
5 | 7 | equemene | * termination.
|
6 | 7 | equemene | * AUTHOR: Blaise Barney
|
7 | 7 | equemene | * LAST REVISED: 08/09/11
|
8 | 7 | equemene | ******************************************************************************/
|
9 | 7 | equemene | #include <pthread.h> |
10 | 7 | equemene | #include <stdio.h> |
11 | 7 | equemene | #include <stdlib.h> |
12 | 7 | equemene | #define NUM_THREADS 4 |
13 | 7 | equemene | |
14 | 7 | equemene | #include <math.h> |
15 | 7 | equemene | #include <stdio.h> |
16 | 7 | equemene | |
17 | 7 | equemene | // Marsaglia RNG very simple implementation
|
18 | 7 | equemene | #define znew ((z=36969*(z&65535)+(z>>16))<<16) |
19 | 7 | equemene | #define wnew ((w=18000*(w&65535)+(w>>16))&65535) |
20 | 7 | equemene | #define MWC (znew+wnew)
|
21 | 7 | equemene | #define SHR3 (jsr=(jsr=(jsr=jsr^(jsr<<17))^(jsr>>13))^(jsr<<5)) |
22 | 7 | equemene | #define CONG (jcong=69069*jcong+1234567) |
23 | 7 | equemene | #define KISS ((MWC^CONG)+SHR3)
|
24 | 7 | equemene | |
25 | 7 | equemene | #define MWCfp MWC * 2.328306435454494e-10f |
26 | 7 | equemene | #define KISSfp KISS * 2.328306435454494e-10f |
27 | 7 | equemene | |
28 | 7 | equemene | #define ITERATIONS 1000000000 |
29 | 7 | equemene | |
30 | 7 | equemene | int MainLoopGlobal(unsigned int iterations,unsigned int seed_w,unsigned int seed_z) |
31 | 7 | equemene | { |
32 | 7 | equemene | unsigned int z=seed_z; |
33 | 7 | equemene | unsigned int w=seed_w; |
34 | 7 | equemene | |
35 | 7 | equemene | int total=0; |
36 | 7 | equemene | |
37 | 7 | equemene | for (unsigned int i=0;i<iterations;i++) { |
38 | 7 | equemene | |
39 | 7 | equemene | float x=MWCfp ;
|
40 | 7 | equemene | float y=MWCfp ;
|
41 | 7 | equemene | |
42 | 7 | equemene | // Matching test
|
43 | 7 | equemene | int inside=((x*x+y*y) < 1.0f) ? 1:0; |
44 | 7 | equemene | total+=inside; |
45 | 7 | equemene | } |
46 | 7 | equemene | |
47 | 7 | equemene | return(total);
|
48 | 7 | equemene | |
49 | 7 | equemene | } |
50 | 7 | equemene | |
51 | 7 | equemene | void *PrintHello(void *threadid) |
52 | 7 | equemene | { |
53 | 7 | equemene | long tid;
|
54 | 7 | equemene | tid = (long)threadid;
|
55 | 7 | equemene | printf("Hello World! It's me, thread #%ld!\n", tid);
|
56 | 7 | equemene | |
57 | 7 | equemene | pthread_exit(NULL);
|
58 | 7 | equemene | } |
59 | 7 | equemene | |
60 | 7 | equemene | void *MainLoopThread(void *threadid) |
61 | 7 | equemene | { |
62 | 7 | equemene | long tid;
|
63 | 7 | equemene | tid = (long)threadid;
|
64 | 7 | equemene | printf("Hello World! It's me, thread #%ld!\n", tid);
|
65 | 7 | equemene | |
66 | 7 | equemene | /* unsigned int z=seed_z; */
|
67 | 7 | equemene | /* unsigned int w=seed_w; */
|
68 | 7 | equemene | unsigned int z=16; |
69 | 7 | equemene | unsigned int w=64; |
70 | 7 | equemene | |
71 | 7 | equemene | int total=0; |
72 | 7 | equemene | |
73 | 7 | equemene | for (unsigned int i=0;i<ITERATIONS;i++) { |
74 | 7 | equemene | |
75 | 7 | equemene | float x=MWCfp ;
|
76 | 7 | equemene | float y=MWCfp ;
|
77 | 7 | equemene | |
78 | 7 | equemene | // Matching test
|
79 | 7 | equemene | int inside=((x*x+y*y) < 1.0f) ? 1:0; |
80 | 7 | equemene | total+=inside; |
81 | 7 | equemene | } |
82 | 7 | equemene | |
83 | 7 | equemene | printf("In #%ld, found %i inside\n",tid,total);
|
84 | 7 | equemene | |
85 | 7 | equemene | pthread_exit(NULL);
|
86 | 7 | equemene | } |
87 | 7 | equemene | |
88 | 7 | equemene | int main(int argc, char *argv[]) |
89 | 7 | equemene | { |
90 | 7 | equemene | pthread_t threads[NUM_THREADS]; |
91 | 7 | equemene | int rc;
|
92 | 7 | equemene | long t;
|
93 | 7 | equemene | for(t=0;t<NUM_THREADS;t++){ |
94 | 7 | equemene | printf("In main: creating thread %ld\n", t);
|
95 | 7 | equemene | rc = pthread_create(&threads[t], NULL, MainLoopThread, (void *)t); |
96 | 7 | equemene | if (rc){
|
97 | 7 | equemene | printf("ERROR; return code from pthread_create() is %d\n", rc);
|
98 | 7 | equemene | exit(-1);
|
99 | 7 | equemene | } |
100 | 7 | equemene | } |
101 | 7 | equemene | |
102 | 7 | equemene | /* Last thing that main() should do */
|
103 | 7 | equemene | pthread_exit(NULL);
|
104 | 7 | equemene | } |