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

实验三 编程模拟生产者和消费者问题
一、实验目的和要求
模拟实现用同步机构避免发生进程执行时可能出现的与时间有关的错误。
进程是程序在一个数据集合上运行的过程，进程是并发执行的，也即系统中的多个进程轮流地占用处理器运行。
我们把若干个进程都能进行访问和修改的那些变量称为公共变量。由于进程是并发地执行的，所以，如果对进程访问公共变量不加限制，那么就会产生“与时间有关”的错误，即进程执行后所得到的结果与访问公共变量的时间有关。为了防止这类错误，系统必须要用同步机构来控制进程对公共变量的访问。一般说，同步机构是由若干条原语——同步原语——所组成。本实习要求学生模拟PV操作同步机构的实现，模拟进程的并发执行，了解进程并发执行时同步机构的作用。
二、实验环境
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;
if s<0 then W (s)
end {p}
procedure 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) 生产者——消费者问题。
假定有一个生产者和一个消费者，生产者每次生产一件产品，并把生产的产品存入共享缓冲器以供消费者取走使用。消费者每次从缓冲器内取出一件产品去消费。禁止生产者将产品放入已满的缓冲器内，禁止消费者从空缓冲器内以产品。假定缓冲器内可同时存放10件产品。那么，用PV操作来实现生产者和消费者之间的同步，生产者和消费者两个进程的程序如下：
B: array [0..9] of products;
s1, s2; semaphore;
s1: =10, s2: =0;
IN, out: integer;
IN: =0; out: =0;
cobegin
procedure producer;
c: products;
begin
L1:
Produce (c);
P (s1);
B[IN]: =C;
IN: =(IN+1)mod 10;
V (s2);
goto L1
end;
procedure consumer;
x: products;
begin
L2: p (s2);
x: =B[out];
out: =(out+1) mod10;
v (s1);
consume (x);
goto L2
end;
coend.
其中的semaphore和products是预先定义的两个类型，在模拟实现中semaphore用integer代替，products可用integer或char等代替。
(3) 进程控制块PCB。
为了记录进程执行时的情况，以及进程让出处理器后的状态，断点等信息，每个进程都有一个进程控制块PCB。在模拟实习中，假设进程控制块的结构如图3-1。其中进程的状态有：运行态、就绪态、等待态和完成态。当进程处于等待态时，在进程控制块PCB中要说明进程等待原因（在模拟实习中进程等待原因是为等待信号量s1或s2）；当进程处于等待态或就绪态时，PCB中保留了断点信息，一旦进程再度占有处理器则就从断点位置继续运行；当进程处于完成状态，表示进程执行结束。
进程名
状态
等待原因
断点
图3-1 进程控制块结构
(4) 处理器的模拟。
计算机硬件提供了一组机器指令，处理器的主要职责是解释执行机器指令。为了模拟生产者和消费者进程的并发执行，我们必须模拟一组指令和处理职能。
模拟的一组指令见图3-2，其中每条指令的功能由一个过程来实现。用变量PC来模拟“指令计数器”，假设模拟的指令长度为1，每执行一条模拟指令后，PC加1，提出下一条指令地址。使用模拟的指令，可把生产者和消费者进程的程序表示为图3-3的形式。
定义两个一维数组PA[0..4]和SA[0..4]，每一个PA[i]存放生产者程序中的一条模拟指令执行的入口地址；每个SA[i]存放消费者程序中的一条模拟指令执行的入口地址。于是模拟处理器执行一条指令的过程为：取出PC之值，按PA[PC]或SA[PC]得模拟指令执行的入口地址，将PC之值加1，转向由入口地址确定的相应的过程执行。

模拟的指令
功 能
p (s)
执行P操作原语
v (s)
执行V操作原语
put
B[IN]: =product; IN: = (IN+1) mod 10
GET
x: =B[out]; out: =(out+1) mod 10
produce
输入一个字符放入C中
consume
打印或显示x中的字符
GOTO L
PC: =L
NOP
空操作
图3-2 模拟的处理器指令

序号
生产者程序
消费者程序
0
produce
p (s2)
1
p (s1)
GET
2
PUT
v (s1)
3
v (s2)
consume
4
goto 0
goto 0
图3-3 生产者和消费者程序

(5) 程序设计
本实习中的程序由三部分组成：初始化程序、处理器调度程序、模拟处理器指令执行程序。各部分程序的功能及相互间的关系由图3-4至图3-7指出。

图3-4 初始化流程

图3-5 模拟处理器调度

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

图3-6 模拟处理器指令执行
(a) 模拟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中指出。

附录：代码
#include <stdio.h>
#include <stdlib.h>
#include <conio.h>
#include <windows.h>
#define NULL 0
struct spcb
{
char 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 array[10];
char c,x;
int pa[6],sa[6];

int p(int s) /* p操作原语 */
{
s=s-1;
if(s<0)
{
process->state='B'; /* B表示阻塞*/
process->why='s';
}
else
{
process->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 arr[10]={'a','b','c','d','e','f','g','h','i','j'};
return arr[abs(rand()%10)];
}

void put()
{
// printf("\n please product anychar!");
// scanf("\n%c",&c);
Sleep(1000);
array[in]=RanChar();
in=(in+1)%10;
printf(" product a char is %c!\n ",array[in-1]);
int k = 0;
for(m=0;m<10;m++)
{
if (array[m]!=' ') {
printf("%c",array[m]);
k = k+1;
}

}
printf("缓冲池中有%d个产品\n",k);
}
void get()
{
Sleep(1000);
x=array[out];
printf("\n%c get a char fron buffer",x);
printf("\n");
array[out]=' ';
out=(out+1)%10;
int k = 0;
for(m=0;m<10;m++)
{
if (array[m]!=' ') {
printf("%c",array[m]);
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("|%c\t",process->name);
printf("|%c\t",process->state);
printf("|%c\t",process->why);
printf("|%d\t",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';
consumer.why=' ';
consumer.dd=0;
for(int k=0;k<10;k++)
{
array[k] = ' ';
}
}

void bornpa() /*将生产者程序装入pa[]中*/
{
for(i=0;i<=3;i++)
{
pa[i]=i;
}
}

void bornsa()/*将消费者程序装入sa[]中*/
{
for(i=0;i<=3;i++)
{
sa[i]=i;
}
}
void diaodu()/*处理器调度程序*/
{
while((producter.state=='W')||(consumer.state=='W'))
{
x=rand();/*x随机获得一个数*/
x=x%2;/*对X取于*/
if(x==0)/*若X等于零，则执行生产者进程，反之执行消费者进程*/
{
process=&producter;/*process表示现行进程，将现行进程置为生产者进程*/
process1=&consumer;
}
else
{
process=&consumer;
process1=&producter;
}
pc=process->dd;
i=pc;/*此时把PC的值付给I*/
if((process->name=='p')&&(process->state=='W'))
{

j=pa[i];
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=='W'))/*执行消费者进程且该进程处于就绪状态*/
{
process->state='W';
j=sa[i];
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();
}

其中专业理论知识内容包括：保安理论知识、消防业务知识、职业道德、法律常识、保安礼仪、救护知识。作技能训练内容包括：岗位操作指引、勤务技能、消防技能、军事技能。
二．培训的及要求培训目的
安全生产目标责任书
为了进一步落实安全生产责任制，做到“责、权、利”相结合，根据我公司2015年度安全生产目标的内容，现与财务部签订如下安全生产目标：
一、目标值：
1、全年人身死亡事故为零，重伤事故为零，轻伤人数为零。
2、现金安全保管，不发生盗窃事故。
3、每月足额提取安全生产费用，保障安全生产投入资金的到位。
4、安全培训合格率为100%。
二、本单位安全工作上必须做到以下内容：
1、对本单位的安全生产负直接领导责任，必须模范遵守公司的各项安全管理制度，不发布与公司安全管理制度相抵触的指令，严格履行本人的安全职责，确保安全责任制在本单位全面落实，并全力支持安全工作。
2、保证公司各项安全管理制度和管理办法在本单位内全面实施，并自觉接受公司安全部门的监督和管理。
3、在确保安全的前提下组织生产，始终把安全工作放在首位，当“安全与交货期、质量”发生矛盾时，坚持安全第一的原则。
4、参加生产碰头会时，首先汇报本单位的安全生产情况和安全问题落实情况；在安排本单位生产任务时，必须安排安全工作内容，并写入记录。
5、在公司及政府的安全检查中杜绝各类违章现象。
6、组织本部门积极参加安全检查，做到有检查、有整改，记录全。
7、以身作则，不违章指挥、不违章操作。对发现的各类违章现象负有查禁的责任，同时要予以查处。
8、虚心接受员工提出的问题，杜绝不接受或盲目指挥；
9、发生事故，应立即报告主管领导，按照“四不放过”的原则召开事故分析会，提出整改措施和对责任者的处理意见，并填写事故登记表，严禁隐瞒不报或降低对责任者的处罚标准。
10、必须按规定对单位员工进行培训和新员工上岗教育；
11、严格执行公司安全生产十六项禁令，保证本单位所有人员不违章作业。
三、 安全奖惩：
1、对于全年实现安全目标的按照公司生产现场管理规定和工作说明书进行考核奖励；对于未实现安全目标的按照公司规定进行处罚。
2、每月接受主管领导指派人员对安全生产责任状的落