互斥锁

  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被阻塞在上锁此刻，之前的语句不会被阻塞 。