#include <stdio.h> #include <stdlib.h> #include"unistd.h" //#ifndef "unistd.h" #define "unistd.h" #include <io.h> #include <process.h>#endif /* _UNISTD_H */ //#include"pthread.h" #include"semaphore.h" #include"fcntl.h" #include "errno.h" #define N 5 //引入3个信号量:mutex,customers,barbers; sem_t mutex,customers,barber; int waiting =0; int chair [5]; void *barbers(); void *customer(); int main(int argc,char *argv[]) //定义10个信号量和一个理发师信号量 pthread_t Customer_id[10],Barbers_id; int i; sem_init(&mutex,0,1); //init mutex semaphore to 1 sem_init (&barber,0,1); sem_init(&customers,0,0); //init semaphore customers to 0 //creat barber pthread void *barber() {int i; int next; //wait(customers),如果没有顾客，理发师休息 sem_wait(&customers) sem_wait (&mutex) //wait(mutex) waiting--; //the number of waiting reduce one for(i=0,i<5;i++) {for (i=0;i<5;i++) pthread_creat(&Barber_id,null,(void)*barber null); for (i=0,i<10,i++) pthread_creat(&Customer_id[],null,(void)*customer,(void)*(i+1) ); for (i=0,i<10,i++) pthread_join(&Barber_id[i],null); for (i=0,i<5;i++) {pthread_join(&Barber_id,null); return 0;} if (char[i]!=0) {next=chair[i]; chair[i]=0 break; } printf("理发师正在为第%d顾客理发\n",next); sleep(3); sem_post(&mutex); sem_post(&barber); } //creat customer pthread void *customer(void *arg) {int i; sem_wait(&mutex); //等待（&mutex）if(等待人数<n) if (waiting<n) { waiting++;//等待数加1 for(i=0,i<5;i++) { if chair[i]==0} { chair[i]=(int)arg; break; } } printf("*************************\n"); printf("进入：数字是%d 顾客进来，坐在%的椅子\n",(int)arg,(i+1)); printf("这有%d个顾客在等待椅上\n",waiting); printf("顾客位置是 :"); for (i=0,i<5;i++) printf("%d  ,char[i]"); printf("\n"); sleep(1); sem_post(&mutex); //释放signal(mutex) sem_post(&customers); //signal(customers) sem_post(&barber); //signal(barber) } else { printf("数字是%d 进来，没有椅子坐,顾客%d号离开\n"(int)arg,(int)arg); sem_post(&mutex);}}