C语言编程模拟生产者和消费者问题附代码程序

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

2、发执行，了解进程并发执行时同步机构的作 用。二、实验环境Windows操作系统和Visual C+6.0 专业版或企业版三、实验步骤模才KPV操作同步机构，且用pv操作解决生产者一一消费者问题。提示:(1) PV操作同步机构，由P操作原语和V操作原语组成，它们的定义如下：P操作原语P (s):将信号量s减去1,若结果小于0,则执行原语的进程被 置成等待信号量s的状态。V操作原语V (s):将信号量s加1 ,若结果不大于0,则释放一个等待信号 量s的进程。这两条原语是如下的两个过程：procedure p (var s: semaphore);begin s: = s-1;if s0 then

3、W (s)end pprocedure v (var s: semaphore);egin s: = s+1;if s 0 then R (s)end v其中W (s)表示将调用过程的进程置为等待信号量s的状态；R (s)表示释放一个等待信号量s的进程。在系统初始化时应把semaphore定义为某个类型，为简单起见，在模拟实 习中可把上述的semaphore 直接改成integer 。(2)生产者一一消费者问题。假定有一个生产者和一个消费者，生产者每次生产一件产品，并把生产的产 品存入共享缓冲器以供消费者取走使用。消费者每次从缓冲器内取出一件产品去 消费。禁止生产者将产品放入已满的缓冲器内，禁

4、止消费者从空缓冲器内以产品。 假定缓冲器内可同时存放10件产品。那么，用PV操作来实现生产者和消费者 之间的同步，生产者和消费者两个进程的程序如下：B: array 0.9 of products;s1, s2; semaphore;s1: =10, s2: =0;IN, out: integer;IN: =0; out: =0;cobeginprocedure producer;c: products;beginL1:Produce (c);P (s1);BIN: =C;IN: =(IN+1)mod 10;V (s2);goto L1 end; procedure consumer; x:

5、products;beginL2:p (s2);x: =Bout;out: =(out+1) mod10;v (s1);consume (x);goto L2 end;coend.其中的semaphore 和products 是预先定义的两个类型，在模拟实现中 semaphore 用 integer 代替，products 可用 integer 或 char 等代替。(3)进程控制块PCB。为了记录进程执行时的情况，以及进程让出处理器后的状态，断点等信息，每个进程都有一个进程控制块PCBo在模拟实习中，假设进程控制块的结构如图3-1。其中进程的状态有：运行态、就绪态、等待态和完成态。当进程处于

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

7、产者和消费者进程的 程序表示为图3-3的形式。定义两个一维数组PA0.4和SA0.4,每一个PAi存放生产者程序中的一 条模拟指令执行的入口地址；每个 SAi存放消费者程序中的一条模拟指令执行的入口地址。于是模拟处理器执行一条指令的过程为： 取出PC之值，按PAPC 或SAPC得模拟指令执行的入口地址，将PC之值加1 ,转向由入口地址确定的 相应的过程执行。模拟的指令功 能p (s)执行P操作原语v (s)执行V操作原语putBIN: =product;IN: = (IN+1) mod 10GETx: =Bout; out: =(out+1) mod 10produce输入一个字符放入 C中c

8、onsume打印或显示x中的字符GOTO LPC: =LNOP空操作图3-2模拟的处理器指令序号生产者程序消费者程序0producep (s2)1p (s 1)GET2PUTv (si)3v (s 2)consume4goto 0goto 0图3-3生产者和消费者程序(5)程序设计本实习中的程序由三部分组成：初始化程序、处理器调度程序、模拟处理器指令执行程序。各部分程序的功能及相互间的关系由图3-4至图3-7指出。初始化信号量气，回生产者和清苗青遁卷 的PCB中粮春为就蜡, 断点*。格现行进程立为生产 taa. pc虻理腓调度程序图3-4初始化流程图3-5 模拟处理器调度初始化程序:模拟实习的

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

10、进程置为就绪盛1*-将调用V O的进程置物就绪态(a)模寸P P (s)(b)模寸V V (s)图3-7 模才P PV操作的执行模拟处理器指令执行程序：按“指令计数器 PC之值执行指定的指令，且PC加1指向下一条指令。模拟处理器指令执行程序的流程图见图3-6和图3-7另外，为了使得模拟程序有一个结束条件，在图 3-6中附加了 “生产者运行结束”的条件判断，模拟时可以采用人工选择的方法实现。图 3-7给出了 P (s) 和V (s)模拟指令执行过程的流程。其它模拟指令的执行过程已在图 3-2中指出。附录：代码#include #include #include #include #define

11、NULL 0struct spcbchar name;char state;char why;int dd ;)；typedef struct spcb pcb;pcb producter,consumer,*process,*process1;int s1,s2,i,j,in,out,pc,m;char array10;char c,x;int pa6,sa6;int p(int s) /* p操作原语 */s=s-1;if(sstate=B; /* B表示阻塞 */process-why=s;)elseprocess-state=W; /* W表示就绪*/return(s);)int v(

12、int s) /*v操作原语 */(s=s+1;if(sstate=W;)process-state=W;return(s);)char RanChar()(char arr10=a,b,c,d,e,f,g,h,i,j;return arrabs(rand()%10);void put()/ printf(n please product anychar!);/scanf(n%c,&c);Sleep(1000);arrayin=RanChar();in=(in+1)%10;printf( product a char is %c!n ,arrayin-1);int k = 0;for(m=0;

13、m10;m+)if (arraym!= ) printf(%c,arraym);k = k+1;printf(缓冲池中有%d个产品n,k);void get()Sleep(1000);x=arrayout;printf(n%c get a char fron buffer,x);printf(n);arrayout=;out=(out+1)%10;int k = 0;for(m=0;mname);printf(|%ct,process-state);printf(|%ct,process-why);printf(|%dt,process-dd);printf(n);void init()/*初

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

15、sa()/*将消费者程序装入(for(i=0;idd;i=pc;/*此时把PC的值付给I*/if(process-name=p)&(process-state=W)j=pai;pc=i+1;switch(j) (case 0: s1=p(s1);process-dd=pc;break;case 1: put();process-state=W;process-dd=pc;break;case 2: s2=v(s2);process-dd=pc;break;case 3: gotol();process-state=W;process-dd=pc;)else if(process-name=c)&(process-state=W1)/*执行消费者进程且该进程处于就绪状态*/(process-state=W;j=sai;pc=i+1;switch(j)(case 0: s2=p(s2);process-dd=pc;bre