读者写者问题源代码.doc

#include #include #include /* malloc()等 */ #include /* INT_MAX等 */ #include /* EOF(=Z或F6),NULL */ #include /* atoi() */ #include /* eof() */ #include /* floor(),ceil(),abs() */ #include /* exit() */ #include #include using namespace std; #define BUF 10 /缓存的大小 #define MAX 20 /最大可以输入的字符typedef struct Pcb char name10; /进程名char state10; /运行状态char reason10; /若阻塞，其原因int breakp; /断点保护struct Pcb *next; /阻塞时的顺序Pcb,*link;int s1,s2; /信号量link p1;/生产者进程link c1;/消费者进程char strMAX; /输入的字符串char bufferBUF; /缓冲池int len; /输入长度int sp=0; /string的指针int in=0; /生产者指针int out=0; /消费者指针char temp; /供打印的临时产品char rec_pMAX;/生产记录int rp1=0;/生产记录指针char rec_cMAX;/消费记录int rp2=0;/消费记录指针link ready; /就绪队列link b_s1; /s1阻塞队列link b_s2; /s2阻塞队列int pc; /程序计数器int count; /字符计数器int con_cnt; /消费计数器void init(); /初始化void p(int s); /P操作void v(int s); /V操作void block(int s);/阻塞函数void wakeup(int s);/唤醒函数void control(); /处理机调度void processor();/处理机执行void print(); /打印函数void main() printf(*生产者消费者模拟n);printf(-n);printf(*请输入字符串:n);scanf(%s,str); /string数组存放将要产生的字符len=strlen(str);count=len; /输入字符的个数init(); /初始化while(con_cntname,Producer);strcpy(p1-state,Ready);strcpy(p1-reason,Null);p1-breakp=0;p1-next=NULL;c1=(link)malloc(sizeof(Pcb);/建立新的结点,并初始化为消费者strcpy(c1-name,Consumer);strcpy(c1-state,Ready);strcpy(c1-reason,Null);c1-breakp=0;c1-next=NULL;ready=p1;ready-next=c1;/初始化为生产进程在前，消费进程在后c1-next=NULL;b_s1=NULL;b_s2=NULL;/阻塞进程为NULLpc=0;con_cnt=0; /消费计数器void p(int s)if(s=1) /p(s1)s1-;if(s1breakp=pc; /保存断点else /p(s2)s2-;if(s2breakp=pc; /保存断点void v(int s)if(s=1) /v(s1)s1+;if(s1breakp=pc; /保存断点else /v(s2)s2+;if(s2breakp=pc; /保存断点void block(int s)/阻塞函数的定义link p;int num1=0;int num2=0;if(s=1)/生产进程strcpy(p1-state,Block);/改变状态strcpy(p1-reason,S1);/说明原因p=b_s1;while(p)num1+;p=p-next;/p的值为NULL,表示队尾if(!b_s1)b_s1=p1;elsep=p1;p1-next=NULL;printf(t* p1生产进程阻塞了!n);ready-breakp=pc; /保存断点ready=ready-next;/在就绪队列中去掉,指向下一个num1+;else/消费进程strcpy(c1-state,Block);strcpy(c1-reason,S2);p=b_s2;while(p)num2+;p=p-next;/p的值为NULL,表示队尾if(!b_s2)b_s2=c1;elsep=c1;ready-breakp=pc; /保存断点ready=ready-next;/在就绪队列中去掉,指向下一个c1-next=NULL;printf(t* c1消费进程阻塞了!n);num2+;printf(t* 阻塞的生产进程个数为:%dn,num1);printf(t* 阻塞的消费进程个数为:%dn,num2);void wakeup(int s)/唤醒函数的定义link p;link q=ready;if(s=1) /唤醒b_s1队首进程,生产进程队列p=b_s1;b_s1=b_s1-next;/阻塞指针指向下一个阻塞进程strcpy(p-state,Ready);strcpy(p-reason,Null);while(q)/插入就绪队列q=q-next;q=p;p-next=NULL;printf(t* p1生产进程唤醒了!n);else /唤醒b_s2队首进程,消费进程队列p=b_s2;b_s2=b_s2-next;/阻塞指针指向下一个阻塞进程strcpy(p-state,Ready);strcpy(p-reason,Null);while(q-next)/插入就绪队列q=q-next;q-next=p;p-next=NULL;printf(t* c1消费进程唤醒了!n);void control() /处理器调度程序int rd;int num=0;link p=ready; if(ready=NULL) /若无就绪进程,结束return;while(p) /统计就绪进程个数num+;p=p-next;/最终p变为NULLprintf(t* 就绪进程个数为:%dn,num);time_t t; srand(unsigned) time(&t);rd=rand()%num;/随机函数产生随机数if(rd=1)p=ready;ready=ready-next;ready-next=p;p-next=NULL;strcpy(ready-state,Run);strcpy(ready-next-state,Ready);else strcpy(ready-state,Run);pc=ready-breakp;void processor() /模拟处理器指令执行int i;if(strcmp(ready-name,Producer)=0) /当前进程为生产者switch(pc) case 0:/produceprintf(t* 生产者生产了字符%cn,strsp);rec_prp1=strsp;/添加到生产记录 sp=(sp+1)%len;pc+;ready-breakp=pc; /保存断点break;case 1: /p(s1)pc+;p(1);break;case 2: /putbufferin=rec_prp1; /放到缓冲区printf(t* %c字符成功入驻空缓存!n,bufferin);rp1+; in=(in+1)%BUF;pc+;ready-breakp=pc; /保存断点break;case 3: /v(s2)pc+;printf(t* 释放一个s2信号n);v(2);break;case 4:/goto01 printf(t* 生产进程goto 0 操作n);pc=0;count-; /剩余字符个数减1printf(t* 剩余字符count=%d个n,count);ready-breakp=pc; /保存断点if(countstate,Stop);strcpy(p1-reason,Null);ready-breakp=-1;ready=ready-next;/在就绪队列中去掉 else /当前进程为消费者switch(pc)case 0: /p(s2)pc+;p(2); break;case 1: /getprintf(t* 消费者取字符!n);temp=bufferout;out=(out+1)%BUF;pc+;ready-breakp=pc; /保存断点break;case 2: /v(s1)pc+;printf(t* 释放一个s1n);v(1);break;c