高響應(yīng)比算法

#include<stdio.h>#include<malloc.h>#definebuffersize5//5個(gè)緩沖區(qū)intprocessnum=0;//初始化產(chǎn)品數(shù)量structpcb//定義進(jìn)程控制塊PCB{intflag;intnumlabel;charproduct;charstate;structpcb*processlink;}*exe=NULL,*over=NULL;typedefstructpcbPCB;PCB*readyhead=NULL,*readytail=NULL;PCB*consumerhead=NULL,*consumertail=NULL;PCB*producerhead=NULL,*producertail=NULL;intproductnum=0;//產(chǎn)品數(shù)量intfull=0,empty=buffersize;//信號(hào)量charbuffer[buffersize];//緩沖區(qū)intbufferpoint=0;//緩沖區(qū)指針voidlinklist(PCB*p,PCB*listhead){//創(chuàng)立就緒隊(duì)列PCB*cursor=listhead;while(cursor->processlink!=NULL){cursor=cursor->processlink;}cursor->processlink=p;}voidfreelink(PCB*linkhead){PCB*p;while(linkhead!=NULL){p=linkhead;linkhead=linkhead->processlink;free(p);}}voidlinkqueue(PCB*process,PCB**tail)//初始化隊(duì)列{if((*tail)!=NULL){(*tail)->processlink=process;(*tail)=process;}else{printf("隊(duì)列序列化！");}}PCB*getq(PCB*head,PCB**tail){PCB*p;p=head->processlink;if(p!=NULL){head->processlink=p->processlink;p->processlink=NULL;if(head->processlink==NULL)(*tail)=head;}elsereturnNULL;returnp;}boolprocessproc()//初始化進(jìn)程{inti,f,num;charch;PCB*p=NULL;PCB**p1=NULL;printf("\n請(qǐng)輸入但愿產(chǎn)生的進(jìn)程個(gè)數(shù)：");scanf("%d",&num);getchar();for(i=0;i<num;i++){printf("\n請(qǐng)輸入您要產(chǎn)生的進(jìn)程：輸入1為生產(chǎn)者進(jìn)程；輸入2為消費(fèi)者進(jìn)程\n");scanf("%d",&f);getchar();p=(PCB*)malloc(sizeof(PCB));if(!p){printf("內(nèi)存分派失敗");returnfalse;}p->flag=f;processnum++;p->numlabel=processnum;p->state='w';p->processlink=NULL;if(p->flag==1){printf("您要產(chǎn)生的進(jìn)程是生產(chǎn)者，它是第%d個(gè)進(jìn)程。請(qǐng)您輸入您要該進(jìn)程產(chǎn)生的字符：\n",processnum);scanf("%c",&ch);getchar();p->product=ch;productnum++;printf("您要該進(jìn)程產(chǎn)生的字符是%c\n",p->product);}else{printf("您要生產(chǎn)的進(jìn)程是消費(fèi)者，它是第%d個(gè)進(jìn)程。\n",p->numlabel);}linkqueue(p,&readytail);}returntrue;}boolhasElement(PCB*pro)//判斷隊(duì)列中與否有進(jìn)程存在{if(pro->processlink==NULL)returnfalse;elsereturntrue;}boolwaitempty()//判斷生產(chǎn)者等待隊(duì)列與否為空{(diào)if(empty<=0){printf("進(jìn)程%d:緩存區(qū)存數(shù)，緩存區(qū)滿，該進(jìn)程進(jìn)入生產(chǎn)者等待序列\(zhòng)n",exe->numlabel);linkqueue(exe,&producertail);returnfalse;}else{empty--;returntrue;}}voidsignalempty()//喚醒生產(chǎn)者進(jìn)程{PCB*p;if(hasElement(producerhead)){p=getq(producerhead,&producertail);linkqueue(p,&readytail);printf("等待中的生產(chǎn)者進(jìn)程進(jìn)入就緒隊(duì)列，它的進(jìn)程號(hào)是%d\n",p->numlabel);}empty++;}boolwaitfull()//判斷消費(fèi)者等待進(jìn)程隊(duì)列與否為滿{if(full<=0){printf("進(jìn)程%d:緩存區(qū)取數(shù)，緩存區(qū)空，該進(jìn)程進(jìn)入消費(fèi)者等待隊(duì)列\(zhòng)n",exe->numlabel);linkqueue(exe,&consumertail);returnfalse;}else{full--;returntrue;}}voidsignalfull()//喚醒消費(fèi)者進(jìn)程{PCB*p;if(hasElement(consumerhead)){p=getq(consumerhead,&consumertail);linkqueue(p,&readytail);printf("等待中的消費(fèi)者進(jìn)程進(jìn)入就緒隊(duì)列，它的進(jìn)程號(hào)是%d\n",p->numlabel);}full++;}voidproducerrun()//生產(chǎn)者進(jìn)程{if(!waitempty())return;printf("進(jìn)程%d開(kāi)始向緩沖區(qū)存數(shù)%c\n",exe->numlabel,exe->product);buffer[bufferpoint]=exe->product;bufferpoint++;printf("進(jìn)程%d向緩沖區(qū)存數(shù)操作結(jié)束\n",exe->numlabel);signalfull();linklist(exe,over);}voidcomsuerrun()//消費(fèi)者進(jìn)程{if(!waitfull())return;printf("進(jìn)程%d向緩沖區(qū)取數(shù)\n",exe->numlabel);exe->product=buffer[bufferpoint-1];bufferpoint--;printf("進(jìn)程%d向緩沖區(qū)取數(shù)操作結(jié)束，取數(shù)是%c\n",exe->numlabel,exe->product);signalempty();linklist(exe,over);}voiddisplay(PCB*p)//顯示進(jìn)程{p=p->processlink;while(p!=NULL){printf("進(jìn)程%d,它是一種",p->numlabel);p->flag==1?printf("生產(chǎn)者\(yùn)n"):printf("消費(fèi)者\(yùn)n");p=p->processlink;}}voidmain(){charterminate;boolelement;printf("你想開(kāi)始程序嗎?(y/n)");scanf("%c",&terminate);getchar();readyhead=(PCB*)malloc(sizeof(PCB));//初始化隊(duì)列if(readyhead==NULL)return;readytail=readyhead;readyhead->flag=3;readyhead->numlabel=processnum;readyhead->state='w';readyhead->processlink=NULL;consumerhead=(PCB*)malloc(sizeof(PCB));if(consumerhead==NULL)return;consumertail=consumerhead;consumerhead->processlink=NULL;consumerhead->flag=4;consumerhead->numlabel=processnum;consumerhead->state='w';consumerhead->processlink=NULL;producerhead=(PCB*)malloc(sizeof(PCB));if(producerhead=NULL)return;producertail=producerhead;producerhead->processlink=NULL;producerhead->flag=5;producerhead->numlabel=processnum;producerhead->state='w';producerhead->processlink=NULL;over=(PCB*)malloc(sizeof(PCB));if(over==NULL)return;over->processlink=NULL;while(terminate=='y'){if(!processproc())break;element=hasElement(readyhead);while(element){exe=getq(readyhead,&readytail);printf("進(jìn)程%d申請(qǐng)運(yùn)行,它是一種",exe->numlabel);exe->flag==1?printf("生產(chǎn)者\(yùn)n"):printf("消費(fèi)者\(yùn)n");if(exe->flag==1)producerrun();elsecomsuerrun();element=hasElement(readyhead);}printf("就緒隊(duì)列沒(méi)有進(jìn)程\n");if(hasElement(consumerhead)){printf("消費(fèi)者等待隊(duì)列中有進(jìn)程：\n");display(consumerhead);}else{printf("消費(fèi)者等待隊(duì)列中沒(méi)有進(jìn)程\n");}if(hasElement(producerhead)){printf("生產(chǎn)者等待隊(duì)列中有進(jìn)程：\n");display(producerhead);}else{printf("生產(chǎn)者等待隊(duì)列中沒(méi)有進(jìn)程\n");}printf("你想繼續(xù)嗎？(press'Y'foron)");scanf("%c",&terminate);getc