操作系统读者写者实验.docxVIP

操作系统实验读者写者问题实现 实验内容利用信号量互斥实现读者写者问题。读者优先与写者优先。实验要求 读者优先，当有读者时写者一直等待，再来的读者先于等待的写者运行。当有读者和写者都在等待时，上一个进程结束后先唤醒读者进程。写者优先，当有写者在等待时，再来的读者也挂在等待队列。上一个进程执行完成后，先唤醒写者进程。源代码：#includestdio.h#includestdlib.hint rcount=0;//正在读的读者数量int wcount=0;//写者队列中等待写操作的写者数量int read_id=0;//读进程号int write_id=0;//写进程号int w=1;//读写互斥信号量char temp[300] = {\0};int choice; //用户选择读者优先OR写者优先int sign; //标识temp空的信号量 0表示temp空void WFwakeup();void RFwakeup();struct rqueue{//读者等待队列int readers[200];int index;}rq;struct wqueue{//写者等待队列int writers[200];int index;}wq;//*******************************************读进程读操作void read1(){int i = 0;read_id++;if(rcount == 0){//当前没有读进程在读 可能有写进程在写 可能CPU空闲if(w==1) {//如果CPU空闲，读者拿到CPUw--;// 相当于一个P操作rcount++;if(temp[0] == \0){sign = 0;if(choice == 1){rq.readers[rq.index++]=read_id;//将读者进程加入等待队列RFwakeup();return;}else{rq.readers[rq.index++]=read_id;//将读者进程加入等待队列WFwakeup();return;}}//ifprintf(读者%d正在读\n,read_id);for(i = 0;i 300;i++){//读取temp内容 即写者写的内容if(temp[i] == \0){printf(\n);return;}//ifprintf(%c,temp[i]);}//for}//ifelse{//写者线程正在执行printf(！有写者在写不能读！\n);rq.readers[rq.index++]=read_id;//将读者进程加入等待队列}//else}//ifelse{//rcount !=1 则知道当前已经有读者在读，读读不互斥，则这个读者可以直接进来了读printf(读者%d正在读\n,read_id);for(i = 0;i 300;i++){if(temp[i] == \0){printf(\n);return;}printf(%c,temp[i]);}//for}//else}void read2(){int i = 0;read_id++;if(rcount == 0){//当前没有读进程在读 可能有写进程在写 可能CPU空闲if(w==1) {//如果CPU空闲，读者拿到CPUw--;// 相当于一个P操作rcount++;if(temp[0] == \0){sign = 0;if(choice == 1){rq.readers[rq.index++]=read_id;//将读者进程加入等待队列RFwakeup();return;}else{rq.readers[rq.index++]=read_id;//将读者进程加入等待队列WFwakeup();return;}}//ifprintf(读者%d正在读\n,read_id);for(i = 0;i 300;i++){//读取temp内容 即写者写的内容if(temp[i] == \0){printf(\n);return;}//ifprintf(%c,temp[i]);}//for}//ifelse{//写者线程正在执行rq.readers[rq.index++]=read_id;printf(！有写者在写不能读！\n);rq.readers[rq.index++]=read_id;//将读者进程加入等待队列}//else}//ifelse{//rcount !=1 则知道当前已经有读者在读，读读不互斥，则这个读者可以直接进来了读if(wcount==0){rq.readers[rq.index++]=read_id; printf(读者%d正在读\n,read_id); for(i = 0;i 300;i++){ if(