9_3_pthread_shared_data_lock.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>// strerror 
#include <unistd.h>// 进程 
#include <errno.h>//errno 
#include <pthread.h>//线程 
 void error(char* msg)
 {
   fprintf(stderr, "%s: %s\n", msg, strerror(errno));
   exit(1);
 }
 int beers = 2000000;//总数 
 // void* 类型 
 void* drink_lots_lock1()
 {
   int i;
   pthread_mutex_t a_lock = PTHREAD_MUTEX_INITIALIZER;//初始化锁 
   pthread_mutex_lock(&a_lock);//启动锁   与 pthread_mutex_unlock(&a_lock);//解锁  之间 同时只能通过一个线程 
   for (i = 0; i < 100000; i++) {
     beers = beers - 1;//每次 -1 
   }
   pthread_mutex_unlock(&a_lock);//解锁 
   return NULL;
 }
 // 上面的lock  每个线程 一次 喝掉 100000 瓶啤酒
 
  
  // void* 类型 
 void* drink_lots_lock2()
 {
   int i;
   for (i = 0; i < 100000; i++) {
   	 pthread_mutex_t a_lock = PTHREAD_MUTEX_INITIALIZER;//初始化锁 
     pthread_mutex_lock(&a_lock);//启动锁   与 pthread_mutex_unlock(&a_lock);//解锁  之间 同时只能通过一个线程 
     beers = beers - 1;//每次 -1 
     pthread_mutex_unlock(&a_lock);//解锁 
   }
   return NULL;
 }
  // 上面的lock  每个线程 一次 喝掉 1 瓶啤酒
 
 int main()
 {
   pthread_t threads[20];//进程信息 
   int t;
   printf("%i bottles of beer on the wall\n%i bottles of beer\n", beers, beers);
   for (t = 0; t < 20; t++) {
     pthread_create(&threads[t], NULL, drink_lots_lock1, NULL);//创建进程 
     //pthread_create(&threads[t], NULL, drink_lots_lock2, NULL);//创建进程 
   }
   void* result;
   for (t = 0; t < 20; t++) {
     pthread_joint(threads[t], &result);//等待进程结束 
   }
   printf("There are now %i bottles of beer on the wall\n", beers);
   return 0;
 }