多线程的广播

 1 #include <pthread.h>
 2 #include <stdio.h>
 3 #include <unistd.h>
 4 
 5 //static     int x = 0;
 6 pthread_mutex_t mutex1 = PTHREAD_MUTEX_INITIALIZER;
 7 pthread_cond_t  cond1  = PTHREAD_COND_INITIALIZER;
 8 
 9 void* doit(void *p)
10 {
11     sleep(*(int *)p);
12     pthread_mutex_lock(&mutex1);
13     //if( x == 0)
14     {
15         printf("pthread_id: %d, wait for command.\n", pthread_self());
16         pthread_cond_wait(&cond1,&mutex1);
17     }
18     printf("I %d got command,let‘s go.\n", pthread_self());
19     pthread_mutex_unlock(&mutex1);
20     return NULL;
21 }
22 
23 
24 int main()
25 {
26     pthread_t pth_array[5];
27     
28     int i=0;
29     for(;i<5;i++)
30     {
31         pthread_create(&pth_array[i],NULL,doit,&i);
32     }
33     
34 
35     pthread_mutex_lock(&mutex1);
36 
37     pthread_cond_broadcast(&cond1);
38     pthread_mutex_unlock(&mutex1);
39 
40     
41     i=0;
42     for(;i<5;i++)
43     {
44         pthread_join(pth_array[i],NULL);
45     }
46     
47     return 0;
48 }