C语言编程模拟生产者和消费者问题.doc

1、Important & Selected Documents实验三编程模拟生产者和消费者问题一、实验目的和要求模拟实现用同步机构避免发生进程执行时可能出现的与时间有关的错误。 进程是程序在一个数据集合上运行的过程， 进程是并发执行的， 也即系统中 的多个进程轮流地占用处理器运行。我们把若干个进程都能进行访问和修改的那些变量称为公共变量。 由于进程 是并发地执行的，所以，如果对进程访问公共变量不加限制，那么就会产生“与 时间有关” 的错误，即进程执行后所得到的结果与访问公共变量的时间有关。 为 了防止这类错误，系统必须要用同步机构来控制进程对公共变量的访问。 一般说， 同步机构是由若干条原语同步

2、原语所组成。 本实习要求学生模拟 PV 操 作同步机构的实现，模拟进程的并发执行， 了解进程并发执行时同步机构的作用。二、实验环境Windows 操作系统和 VisualC+6.0 专业版或企业版三、实验步骤模拟 PV 操作同步机构，且用 PV 操作解决生产者消费者问题。 提示：PV操作同步机构，由P操作原语和V操作原语组成，它们的定义如下：P操作原语P(s):将信号量s减去1,若结果小于0，则执行原语的进程被置 成等待信号量 s 的状态。V操作原语V(s):将信号量s加1,若结果不大于0,则释放一个等待信号 量 s 的进程。这两条原语是如下的两个过程：procedurep(vars:sema

3、phore);begins:=s-1;ifs0thenW(s)endpImportant & Selected Documentsprocedurev(vars:semaphore);egins:=s+1;ifs 0thenR(s)endv其中W (s)表示将调用过程的进程置为等待信号量s的状态；R (s)表示释放一个等待信号量s的进程。在系统初始化时应把semaphore定义为某个类型，为简单起见，在模拟实习 中可把上述的semaphore直接改成integer。(2) 生产者消费者问题。假定有一个生产者和一个消费者， 生产者每次生产一件产品， 并把生产的产 品存入共享缓冲器以供消费者取走使

4、用。 消费者每次从缓冲器内取出一件产品去 消费。禁止生产者将产品放入已满的缓冲器内， 禁止消费者从空缓冲器内以产品。 假定缓冲器内可同时存放 10件产品。那么，用 PV 操作来实现生产者和消费者 之间的同步，生产者和消费者两个进程的程序如下：B:array0.9ofproducts;s1,s2;semaphore;s1:=10,s2:=0;IN,out:integer;IN:=0;out:=0;cobeginprocedureproducer;c:products;beginL1:Produce(c);P(s1);BIN:=C;IN:=(IN+1)mod10;V(s2);gotoL1end;p

5、rocedureconsumer;G:products;beginImporta nt & Selected Docume ntsL2:p(s2);G:=Bout;out:=(out+1)mod10;v(s1);con sume(G);gotoL2end;coe nd.其中的semaphore和products是预先定义的两个类型，在模拟实现中 semaphore用 integer 代替，products可用 integer或 char等代替。(3) 进程控制块PCB。为了记录进程执行时的情况，以及进程让出处理器后的状态，断点等信息， 每个进程都有一个进程控制块PCB。在模拟实习中，假设进程控

6、制块的结构如图3-1。其中进程的状态有：运行态、就绪态、等待态和完成态。当进程处于等 待态时，在进程控制块 PCB中要说明进程等待原因(在模拟实习中进程等待原 因是为等待信号量s1或s2);当进程处于等待态或就绪态时，PCB中保留了断 点信息，一旦进程再度占有处理器则就从断点位置继续运行；当进程处于完成状态，表示进程执行结束。程名 |状态 等待原因|断点 图3-1进程控制块结构(4) 处理器的模拟。计算机硬件提供了一组机器指令，处理器的主要职责是解释执行机器指令。 为了模拟生产者和消费者进程的并发执行，我们必须模拟一组指令和处理职能。模拟的一组指令见图3-2,其中每条指令的功能由一个过程来实现

7、。用变量 PC来模拟“指令计数器”，假设模拟的指令长度为1,每执行一条模拟指令后， PC加1,提出下一条指令地址。使用模拟的指令，可把生产者和消费者进程的 程序表示为图3-3的形式。定义两个一维数组PA0.4和SA0.4，每一个PAi存放生产者程序中的一 条模拟指令执行的入口地址；每个SAi存放消费者程序中的一条模拟指令执行的入口地址。于是模拟处理器执行一条指令的过程为：取出PC之值，按PAPC或SAPC得模拟指令执行的入口地址，将PC之值加1,转向由入口地址确定的 相应的过程执行。功能模拟的指令Importa nt & Selected Docume ntsp(s)执行P操作原语v(s)r执

8、行v操作原语putBIN:=product;IN:=(IN+1)mod10GETG:=Bout;out:=(out+1)mod10produce输入一个字符放入C中con sume打印或显示G中的字符GOTOLPC:=LNOP空操作图3-2模拟的处理器指令序号生产者程序消费者程序0producep(S2)1p(si)GET2PUTV（S1）3V（S2）con sume4gotoOgoto0图3-3生产者和消费者程丿（5）程序设计本实习中的程序由三部分组成：初始化程序、处理器调度程序、模拟处理器 指令执行程序。各部分程序的功能及相互间的关系由图3-4至图3-7指出。图3-4初始化流程图3-5模拟

9、处理器调度初始化程序：模拟实习的程序从初始化程序入口启动，初始化工作包括对 信号量s1、s2赋初值，对生产者、消费者进程的 PCB初始化。初始化后转向处 理调度程序，其流程如图3-4。处理器调度程序：在计算机系统中，进程并发执行时，任一进程占用处理 器执行完一条指令后就有可能被打断而让出处理器由其它进程运行。故在模拟系统中也类似处理，每当执行一条模拟的指令后，保护当前进程的现场，让它成为非运行态，由处理器调度程序按随机数再选择一个就绪进程占用处理器运行。处Importa nt & Selected Docume nts理器调度程序流程见图3-5图3-6模拟处理器指令执行常坍用PG过程 的进程为

10、芳持 倍号奪的状态二L将调用p的 进程畫为M迅将调用 $)的进 程倉为就编态模拟P(s)(b)模拟V(s)图3-7模拟PV操作的执行模拟处理器指令执行程序：按“指令计数器”PC之值执行指定的指令，且PC加1指向下一条指令。模拟处理器指令执行程序的流程图见图3-6和图3-7另外，为了使得模拟程序有一个结束条件，在图3-6中附加了 “生产者运行结束”的条件判断，模拟时可以采用人工选择的方法实现。图3-7给出了 P(s)和V (s)模拟指令执行过程的流程。其它模拟指令的执行过程已在图3-2中指附录：代码#in clude#in clude#in clude#in clude#defi neNULLO

11、structspcbchar name;charstate;charwhy;in tdd;typedefstructspcbpcb;pcbproducter,c on sumer,Gprocess,Gprocess1; in ts1,s2,i,j,i n,o ut,pc,m;chararray10;charc,G;in tpa6,sa6;intp(ints)/Gp 操作原语 G/s=s-1;Important & Selected Documentsif(sstate=B;/GB 表示阻塞 G/process-why=s;elseprocess-state=W;/GW 表示就绪 G/retur

12、n(s);intv(ints)/Gv 操作原语 G/s=s+1;if(sstate=W;process-state=W;return(s);charRanChar() chararr10=a,b,c,d,e,f,g,h,i,j; returnarrabs(rand()%10);voidput()/ printf(npleaseproductanychar!);/ scanf(n%c,&c);Sleep(1000);arrayin=RanChar();in=(in+1)%10; printf(productacharis%c!n,arrayin-1); intk=0;for(m=0;m10;m+

13、)if(arraym!=) printf(%c,arraym); k=k+1;printf( 缓冲池中有 %d 个产品 n,k);voidget()Sleep(1000);G=arrayout;printf(n%cgetacharfronbuffer,G);printf(n);arrayout=;out=(out+1)%10;intk=0;for(m=0;mname); printf(|%ct,process-state); printf(|%ct,process-why); printf(|%dt,process-dd); printf(n);voidinit()/G 初始化程序 G/ s1

14、=10;/Gs1 表示空缓冲区的数量 G/ s2=0;/Gs2 表示满缓冲区的数量 G/ =p;/G 对生产者进程初始化 G/ producter.state=W; producter.why=; producter.dd=0;=c;/G 对消费者进程初始化 G/ consumer.state=W;consumer.why=; consumer.dd=0;for(intk=0;k10;k+)arrayk=;voidbornpa()/G 将生产者程序装入 pa 中 G/ for(i=0;i=3;i+) pai=i;voidbornsa()/G

15、将消费者程序装入 sa中G/ for(i=0;idd;i=pc;/G 此时把 PC 的值付给 IG/ if(process-name=p)&(process-state=W)j=pai;pc=i+1;switch(j)case0:s1=p(s1);process-dd=pc;break;case1:put();process-state=W;process-dd=pc;break;case2:s2=v(s2);process-dd=pc;break;case3:gotol();process-state=W;process-dd=pc;elseif(process-name=c)&(process-state=W)/G 执行消费者进程且该进程处于就绪状态 G/process-state=W;j=sai;pc=i+1;switch(j)case0:s2=p(s2);proce