- 论坛徽章:
- 0
|
1 #include
2 #include
3 int a = 0;
4
5 pthread_mutex_t number;
6 void * th_1(void *arg)
7 {
8 pthread_mutex_lock(&number);
9 a = a + 1;
10 printf("%d\n",a);
11 sleep(3);
12 a = a + 1;
13 printf("%d\n",a);
14 pthread_mutex_unlock(&number);
15 }
16 void * th_2(void*arg)
17 {
18 pthread_mutex_lock(&number);
19 printf("wait for th_2:\n");
20 printf("%d\n",a);
21 a = a + 1;
22 printf("%d\n",a);
23 pthread_mutex_unlock(&number);
24 }
25 int main(void)
26 {
27
28 pthread_t th1;
29 pthread_t th2;
30 pthread_create(&th1,NULL,(void*)th_1,NULL);
31 pthread_create(&th2,NULL,(void*)th_2,NULL);
32 sleep(4);
33
34 }
th_1和th_2分别对全局变量a进行改变,加了互斥锁之后,th_1不受th_2的干扰,th_2被阻塞一直到th_1解锁后,之后才能对a进行修改。而且th_2被阻塞在上锁此刻,之前的语句不会被阻塞 。
本文来自ChinaUnix博客,如果查看原文请点:http://blog.chinaunix.net/u3/108685/showart_2129155.html |
|