1 #include "stdafx.h"
  2 #include <stdio.h>
  3 #include <pthread.h>
  4 #include <sched.h> 
  5 #include <semaphore.h> 
  6 #include <conio.h>
  7 #include <ctype.h>
  8 #include <signal.h>
  9 #include <iostream>
 10 
 11 #include<Windows.h>
 12 using namespace std;
 13 #pragma comment(lib,"pthreadVC2.lib")  
 14 
 15 #define N 5  //消费者或者生产者的数目
 16 #define M 10  //缓冲数目
 17 
 18 int productin = 0; //生产者放置产品的位置
 19 int prochaseout = 0; //消费者取产品的位置
 20 
 21 int buff[M] = {0}; //缓冲区初始化为0，开始时没有产品。
 22 
 23 sem_t empty_sem; // 同步信号量，当满的时候阻止生产者放产品。
 24 sem_t full_sem; //同步信号量，当没有产品的时候阻止消费者消费。
 25 
 26 pthread_mutex_t mutex; //互斥信号量，一次只有一个线程访问缓冲区。
 27 
 28 int product_id = 0; //生产者id
 29 int prochase_id = 0; //消费者id
 30 
 31 void SignalExit(int signo)
 32 {
 33     printf("程序退出%d\n",signo);
 34     return;
 35 }
 36 
 37 void PrintProduction()
 38 {
 39     printf("此时的产品队列为::");
 40     for(int i = 0; i < M; i++ )
 41     {
 42         printf("%d  ",buff[i]);
 43     }
 44     printf("\n\n");
 45 }
 46 
 47 //////////////////////生产者方法////////////////////
 48 void* Product(void* pramter)
 49 {
 50     int id = ++product_id;
 51     while(1)
 52     {
 53         Sleep(5000); //毫秒
 54         sem_wait(&empty_sem); //给信号量减1操作
 55         pthread_mutex_lock(&mutex);
 56         productin = productin % M;
 57         printf("生产者%d在产品队列中放入第%d个产品\n\n",id,productin+1);
 58         buff[productin] = 1;
 59         PrintProduction();
 60         ++productin;
 61 
 62         pthread_mutex_unlock(&mutex); //释放互斥量对象
 63         sem_post(&full_sem); //给信号量的值加1操作
 64     }
 65 }
 66 
 67 //////////////消费者方法///////////////////////
 68 void* Prochase( void* pramter )
 69 {
 70     int id = ++prochase_id;
 71     while(1)
 72     {
 73         Sleep(7000);
 74         sem_wait(&full_sem);
 75         pthread_mutex_lock(&mutex);
 76         prochaseout = prochaseout % M;
 77         printf("消费者%d从产品队列中取出第%d个产品\n\n",id,prochaseout+1);
 78 
 79         buff[prochaseout] = 0;
 80         PrintProduction();
 81         ++prochaseout;
 82 
 83         pthread_mutex_unlock(&mutex);
 84         sem_post(&empty_sem);
 85     }
 86 }
 87 
 88 int main()
 89 {
 90     cout << "生产者和消费者数目都为5,产品缓冲区为10,生产者每2秒生产一个产品，消费者每5秒消费一个产品" << endl << endl;
 91     pthread_t productid[N];
 92     pthread_t prochaseid[N];
 93 
 94     int ret[N];
 95 
 96     //初始化信号量
 97     int seminit1 = sem_init(&empty_sem,0,M);
 98     int seminit2 = sem_init(&full_sem,0,0);
 99     if( seminit1 != 0  && seminit2 != 0 )
100     {
101         printf("sem_init failed !!!\n");
102         return 0;
103     }
104 
105     //初始化互斥信号量
106     int mutexinit = pthread_mutex_init(&mutex,NULL);
107     if( mutexinit != 0 )
108     {
109         printf("pthread_mutex_init failed !!\n");
110         return 0;
111     }
112 
113     //创建n个生产者线程
114     for(int i = 0; i < N; i++ )
115     {
116         ret[i] = pthread_create( &productid[i], NULL,Product,(void*)(&i) );
117         if( ret[i] != 0 )
118         {
119             printf("生产者%d线程创建失败!\n",i);
120             return 0;
121         }
122     }
123 
124     //创建n个消费者线程
125     for(int j = 0; j < N; j++ )
126     {
127         ret[j] = pthread_create(&prochaseid[j],NULL,Prochase,NULL);
128         if( ret[j] != 0 )
129         {
130             printf("消费者%d线程创建失败\n",j);
131             return 0;
132         }
133     }
134 
135     ///////////////////////等待线程被销毁///////////////////////////////////////////////
136     for( int k = 0; k < N; k++ )
137     {
138         printf("销毁线程\n");
139         pthread_join(productid[k],NULL);
140         pthread_join(prochaseid[k],NULL);
141     }
142     return 0;
143 }