《C语言编程模拟生产者和消费者问题附代码程序.docx》由会员分享，可在线阅读，更多相关《C语言编程模拟生产者和消费者问题附代码程序.docx（9页珍藏版）》请在三一文库上搜索。
1、实验三 编程模拟生产者和消费者问题一、实验目的和要求模拟实现用同步机构防止发生进程执行时可能出现的与时间有关的错误。 进程是程序在一个数据集合上运行的过程，进程是并发执行的，也即系统中的多个进 程轮流地占用处理器运行。我们把假设干个进程都能进行访问和修改的那些变量称为公共变量。由于进程是并发地 执行的，所以，如果对进程访问公共变量不加限制，那么就会产生“与时间有关的错误， 即进程执行后所得到的结果与访问公共变量的时间有关。为了防止这类错误，系统必须要 用同步机构来控制进程对公共变量的访问。一般说，同步机构是由假设干条原语同步原 语所组成。本实习要求学生模拟 PV 操作同步机构的实现，模拟进程的
2、并发执行，了 解进程并发执行时同步机构的作用。二、实验环境Windows 操作系统和 Visual C+6.0 专业版或企业版三、实验步骤模拟 PV 操作同步机构，且用 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;
3、if s<0 then W (s)end pprocedure v (var s: semaphore);egin s: = s+1;if s £ 0 the n 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 L1end;proc
5、edure consumer;x: products;beginL2:p (s2);x: =Bout;out: =(out+1) mod10;v (s1);con sume (x);goto L2end;coend.其中的semaphore和products是预先定义的两个类型，在模拟实现中 semaphore用 integer 代替，products可用 integer或 char等代替。(3) 进程控制块PCB。为了记录进程执行时的情况，以及进程让出处理器后的状态，断点等信息，每个进程都有一个进程控制块PCB。在模拟实习中，假设进程控制块的结构如图3-1。其中进程的状态有：运行态、就绪态、
6、等待态和完成态。当进程处于等待态时，在进程控制块PCB中要说明进程等待原因(在模拟实习中进程等待原因是为等待信号量s1或s2)；当进程处于等待态或就绪态时，PCB中保存了断点信息，一旦进程再度占有处理器那么就从断点位置继 续运行；当进程处于完成状态，表示进程执行结束。进程名状态等待原因 |断点图3-1进程控制块结构(4) 处理器的模拟。计算机硬件提供了一组机器指令，处理器的主要职责是解释执行机器指令。为了模拟 生产者和消费者进程的并发执行，我们必须模拟一组指令和处理职能。模拟的一组指令见图3-2,其中每条指令的功能由一个过程来实现。用变量PC来模拟“指令计数器，假设模拟的指令长度为1,每执行一
7、条模拟指令后，PC加1,提出下一条 指令地址。使用模拟的指令，可把生产者和消费者进程的程序表示为图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
8、) mod 10produce输入一个字符放入 C中con sume打印或显示x中的字符GOTO LPC: =LNOP空操作图3-2模拟的处理器指令序号生产者程序消费者程序0produceP (S2)1P (S1)GET2PUTV (S1)3V (S2)con sume4goto 0goto 0图3-3生产者和消费者程序(5) 程序设计本实习中的程序由三局部组成：初始化程序、处理器调度程序、模拟处理器指令执行 程序。各局部程序的功能及相互间的关系由图3-4至图3-7指出。>1 P0桂喪村BEU为生产 片进亦PCi*»图3-4初始化流程图3-5模拟处理器调度初始化程序：模拟实习的
9、程序从初始化程序入口启动，初始化工作包括对信号量S1、s2赋初值，对生产者、消费者进程的 PCB初始化。初始化后转向处理调度程序，其流程 如图3-4。处理器调度程序：在计算机系统中，进程并发执行时，任一进程占用处理器执行完 一条指令后就有可能被打断而让出处理器由其它进程运行。故在模拟系统中也类似处理， 每当执行一条模拟的指令后，保护当前进程的现场，让它成为非运行态，由处理器调度程 序按随机数再选择一个就绪进程占用处理器运行。处理器调度程序流程见图3-5。图3-6模拟处理器指令执行塢调箱过段 的进釋为袴持 愷号将一个導痔和自号量 的进穆畫为就绻憲;(a)模拟 P (s)箱调博(“的进 程養为就绪
10、态(b)模拟 V (s)图3-7模拟PV操作的执行模拟处理器指令执行程序：按“指令计数器PC之值执行指定的指令，且PC加1指向下一条指令。模拟处理器指令执行程序的流程图见图3-6和图3-7。另外，为了使得模拟程序有一个结束条件，在图3-6中附加了“生产者运行结束的条件判断，模拟时可以采用人工选择的方法实现。图3-7给出了 P(s)和V (s)模拟指令执行过程的流程。其它模拟指令的执行过程已在图3-2中指出。附录：代码#i nclude <stdio.h>#i nclude <stdlib.h>#in clude <coni o.h>#i nclude <
11、;win dows.h>#defi ne NULL 0struct spcbchar n ame;char state;char why;int dd ;typedef struct spcb pcb;pcb producter,c on sumer,*process,*process1;int s1,s2,i,j,i n,o ut,pc,m;char array1O;char c,x;int pa6 ,sa 6;int p(int s) /* p 操作原语 */s=s-1;if(s<0)process->state='B' /* B 表示阻塞 */ proc
12、ess->why='s'elseprocess->state='W' /* W 表示就绪 */return(s);int v(int s) /*v 操作原语 */s=s+1;if(s<=0) process1->state='W'process->state='W'return(s);char RanChar()char arr10='a','b','c','d','e','f','g',&
13、#39;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;m<10;m+)if (arraym!='
14、9;) 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;m<10;m+)if (arraym!=' ') printf("%c",arra
15、ym);k = k+1;printf(" 缓冲池中有 %d 个产品 n",k);void gotol()pc=0;void nop();void disp() /* 建立进程显示函数 ,用于显示当前进程 */ printf("n name t state t why t dd n"); printf("|%ct",process->name); printf("|%ct",process->state); printf("|%ct",process->why); printf(
16、"|%dt",process->dd);printf("n");void init()/* 初始化程序 */s1=10;/*s1 表示空缓冲区的数量 */ s2=0; /*s2 表示满缓冲区的数量 */ producter.name='p'/* 对生产者进程初始化 */ producter.state='W'producter.why=' 'producter.dd=0; consumer.name='c'/* 对消费者进程初始化 */ consumer.state='W
17、9;consumer.why=' 'consumer.dd=0;for(int k=0;k<10;k+)arrayk =void bornpa() /*将生产者程序装入 pa中*/for(i=0;i<=3;i+)pai=i;void bornsa()/*将消费者程序装入 sa中*/for(i=0;i<=3;i+)sai=i;void diaodu()/* 处理器调度程序 */ while(producter.state='W')|(consumer.state='W')x=rand();/*x 随机获得一个数 */x=x%2;/
18、* 对 X 取于 */if(x=0)/* 假设 X 等于零，那么执行生产者进程，反之执行消费者进程 */process=&producter;/*process 表示现行进程，将现行进程置为生产者进程 */ process1=&consumer;elseprocess=&consumer;process1=&producter;pc=process->dd;i=pc;/* 此时把 PC 的值付给 I*/if(process->name='p')&&(process->state='W')j=pai
19、;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='
20、W')/* 执行消费者进程且该进程处于就绪状态*/process->state='W'j=sai;pc=i+1;switch(j)case 0: s2=p(s2);process->dd=pc;break;/* 申请资源，假设没有申请到那么跳转 */ case 1: get();process->dd=pc;break;case 2: s1=v(s1);process->dd=pc;break;case 3: gotol();process->state='W'process->dd=pc; /*end else*/*end while*/printf("nThe program is over!n");void main()init();bornpa(); bornsa(); diaodu();