实验四、同步机构

实验四、同步机构一、实习内容模拟实现用同步机构避免发生进程执行时可能出现的与时间有关的错误。二、实习目的进程是程序在一个数据集合上运行的过程，进程是并发执行的，也即系统中的多个进程轮流地占用处理器运行。我们把若干个进程都能进行访问和修改的那些变量称为公共变量。由于进程是并发地执行的，所以，如果对进程访问公共变量不加限制，那么就会产生“与时间有关”的错误，即进程执行后所得到的结果与访问公共变量的时间有关。为了防止这类错误，系统必须要用同步机构来控制进程对公共变量的访问。一般说，同步机构是由若干条原语——同步原语——所组成。本实习要求学生模拟PV操作同步机构的实现，模拟进程的并发执行，了解进程并发执行时同步机构的作用。三、实习题目模拟PV操作同步机构，且用PV操作解决生产者——消费者问题。[提示]：(1)PV操作同步机构，由P操作原语和V操作原语组成，它们的定义如下：P操作原语P(s)：将信号量s减去1，若结果小于0，则执行原语的进程被置成等待信号量s的状态。V操作原语V(s)：将信号量s加1，若结果不大于0，则释放一个等待信号量s的进程。这两条原语是如下的两个过程：procedurep(vars:semaphore);begins:=s-1;ifs0thenW(s)end{p}procedurev(vars:semaphore);egins:=s+1;ifs0thenR(s)end{v}其中W（s）表示将调用过程的进程置为等待信号量s的状态；R（s）表示释放一个等待信号量s的进程。在系统初始化时应把semaphore定义为某个类型，为简单起见，在模拟实习中可把上述的semaphore直接改成integer。(2)生产者——消费者问题。假定有一个生产者和一个消费者，生产者每次生产一件产品，并把生产的产品存入共享缓冲器以供消费者取走使用。消费者每次从缓冲器内取出一件产品去消费。禁止生产者将产品放入已满的缓冲器内，禁止消费者从空缓冲器内以产品。假定缓冲器内可同时存放10件产品。那么，用PV操作来实现生产者和消费者之间的同步，生产者和消费者两个进程的程序如下：B:array[0..9]ofproducts;s1,s2;semaphore;s1:=10,s2:=0;IN,out:integer;IN:=0;out:=0;cobeginprocedureproducer;c:products;beginL1:Produce(c);P(s1);B[IN]:=C;IN:=(IN+1)mod10;V(s2);gotoL1end;procedureconsumer;x:products;beginL2:p(s2);x:=B[out];out:=(out+1)mod10;v(s1);consume(x);gotoL2end;coend.其中的semaphore和products是预先定义的两个类型，在模拟实现中semaphore用integer代替，products可用integer或char等代替。(3)进程控制块PCB。为了记录进程执行时的情况，以及进程让出处理器后的状态，断点等信息，每个进程都有一个进程控制块PCB。在模拟实习中，假设进程控制块的结构如图12-1。其中进程的状态有：运行态、就绪态、等待态和完成态。当进程处于等待态时，在进程控制块PCB中要说明进程等待原因（在模拟实习中进程等待原因是为等待信号量s1或s2）；当进程处于等待态或就绪态时，PCB中保留了断点信息，一旦进程再度占有处理器则就从断点位置继续运行；当进程处于完成状态，表示进程执行结束。进程名状态等待原因断点图12-1进程控制块结构(4)处理器的模拟。计算机硬件提供了一组机器指令，处理器的主要职责是解释执行机器指令。为了模拟生产者和消费者进程的并发执行，我们必须模拟一组指令和处理职能。模拟的一组指令见图12-2，其中每条指令的功能由一个过程来实现。用变量PC来模拟“指令计数器”，假设模拟的指令长度为1，每执行一条模拟指令后，PC加1，提出下一条指令地址。使用模拟的指令，可把生产者和消费者进程的程序表示为图12-3的形式。定义两个一维数组PA[0..4]和SA[0..4]，每一个PA[i]存放生产者程序中的一条模拟指令执行的入口地址；每个SA[i]存放消费者程序中的一条模拟指令执行的入口地址。于是模拟处理器执行一条指令的过程为：取出PC之值，按PA[PC]或SA[PC]得模拟指令执行的入口地址，将PC之值加1，转向由入口地址确定的相应的过程执行。(5)程序设计本实习中的程序由三部分组成：初始化程序、处理器调度程序、模拟处理器指令执行程序。各部分程序的功能及相互间的关系由图12-4至图12-7指出。模拟的指令功能p(s)执行P操作原语v(s)执行V操作原语putB[IN]:=product;IN:=(IN+1)mod10GETx:=B[out];out:=(out+1)mod10produce输入一个字符放入C中consume打印或显示x中的字符GOTOLPC:=LNOP空操作图12-2模拟的处理器指令序号生产者程序消费者程序0producep(s2)1p(s1)GET2PUTv(s1)3v(s2)consume4goto0goto0图12-3生产者和消费者程序·初始化程序：模拟实习的程序从初始化程序入口启动，初始化工作包括对信号量s1、s2赋初值，对生产者、消费者进程的PCB初始化。·处理器调度程序：在计算机系统中，进程并发执行时，任一进程占用处理器执行完一条指令后就有可能被打断而让出处理器由其它进程运行。故在模拟系统中也类似处理，每当执行一条模拟的指令后，保护当前进程的现场，让它成为非运行态，由处理器调度程序按随机数再选择一个就绪进程占用处理器运行。四、实习报告(1)实习题目。(2)打印源程序并附上注释。(3)从键盘上输入一组字符，由生产者每次读入一个字符供消费者输出。运行模拟程序，打印依次读入的字符和经消费者输出的字符。(4)把生产者和消费者进程中的P操作、V操作都改成空操作指令，观察在两者不同步的情况下可能出现的与时间有关的错误。打印依次读入的字符和经消费者输出的字符。五、实习代码#includestdio.h#includemath.h#includestdlib.h#includestring.h#definenum10typedefstructPCB{charstate;//E-运行,R-就绪,W-等待,C-完成intcause;//1-等待信号量S1，2-等待信号量s2intpause;//保存断点信息char*procedure;}PCB;PCBpro;PCB*pronode=&pro;PCBcon;PCB*connode=&con;chari[100];charx,c;//x接受输入字符，c接受输出字符charB[num+1];//存放缓冲区中的商品intin,out;intPC,sum;//程序计数器inta,s1,s2;//s2-缓冲区种商品的数量，s1-缓冲区中还可放入的商品数量inttag,retag;//tag=0-CPU未中断；tag=1-cpu中断intstop;//stop=0-开中断；stop=1-关中断int(*PA[5])(int*s,PCB*P);//生产者指令数组int(*SA[5])(int*s,PCB*p);//消费者指令数组intW(int*s,PCB*q){tag=0;q-state='w';printf(当前%s进程已被更新为阻塞态\n,q-procedure);if(strcmp(q-procedure,生产者)==0)printf(原因为等待信号量s2\n\n);elseprintf(原因为等待信号量s1\n\n);q-cause=2;stop=0;return0;}intR(int*s,PCB*q){printf(进程%s已被更新为就绪态\n,q-procedure);if(strcmp(q-procedure,生产者)==0){printf(原因为信号量s2已满足\n\n);q-state='r';}else{printf(原因为信号量s1已满足\n\n);q-state='r';}q-state='r';q-cause=0;return0;}intp(int*m,PCB*q){stop=1;*m=*m-1;if(*m0)W(m,q);elsestop=0;tag=0;q-pause=PC;return0;}intprov(int*m,PCB*q){stop=1;*m=*m+1;if(*m=0)R(m,q);stop=0;tag=0;pronode-pause=PC;return0;}intconv(int*m,PCB*q){stop=1;*m=*m+1;if(*m=0)R(m,q);stop=0;tag=0;connode-pause=PC;return0;}intPut(int*s,PCB*pro){in=(in+1)%10;B[in]=c;pro-pause=PC;return0;}intGet(int*s,PCB*con){out=(out+1)%10;x=B[out];con-pause=PC;return0;}intconsume(int*s,PCB*q){printf(消费者取出商品%c\n\n,x);q-pause=PC;if(x==i[sum-1])return1;return0;}intproduce(int*s,PCB*q){a++;if(a==sum){retag=1;return0;}else{c=i[a];printf(生产者放入商品%c\n\n,c);q-pause=PC;return0;}}intGoto(int*s,PCB*q){q-pause=PC;PC=0;return0;}intIniPro(){PA[0]=produce;PA[1]=p;PA[2]=Put;PA[3]=prov;PA[4]=Goto;return0;}//消费者程序首地址数组初始化intIniCon(){SA[0]=p;SA[1]=Get;SA[2]=conv;SA[3]=consume;SA[4]=Goto;return0;}//生产者程序首地址数组初始化intcodepro(int*s1,int*s2,PCB*pro,PCB*con){switch(PC){case0:PA[PC](&PC,pro);break;case1:PA[PC](s1,pro);break;case2:PA[PC](&in,pro);break;case3:PA[PC](s2,con);break;case4:PA[PC](s1,pro);break;}return0;}intcodecon(int*s1,int*s2,PCB*pro,PCB*con){switch(PC){case0:SA[PC](s2,con);break;case1:SA[PC](&out,con);break;case2:SA[PC](s1,pro);break;case3:SA[PC](s2,con);break;case4:SA[PC](s2,con);break;}return0;}intcontrol(int*s1,int*s2,PCB*pro,PCB*con){intrandom=rand()%2;if(random==0&&retag==0&&pro-state!='w'){PC=(pro-pause+1)%5;codepro(s1,s2,pro,con);if(pro-state!='w'){PC=(pro-pause+1)%5;codepro(s1,s2,pro,con);}}elseif((random==1||retag==1)&&con-state!='w'){PC=(con-pause+1)%5;codecon(s1,s2,pro,con);if(