资源简介
（1）创建生产者和消费者线程
在Windows2000环境下，创建一个控制台进程，在此进程中创建n个线程来模拟生产者或者消费者。这些线程的信息由本程序定义的“测试用例文件”中予以指定。
该文件的格式和含义如下：
3
1 P 3
2 P 4
3 C 4 1
4 P 2
5 C 3 1 2 4
第一行说明程序中设置几个临界区，其余每行分别描述了一个生产者或者消费者线程的信息。每一行的各字段间用Tab键隔开。不管是消费者还是生产者，都有一个对应的线程号，即每一行开始字段那个整数。第二个字段用字母P或者C区分是生产者还是消费者。第三个字段表示在进入相应线程后，在进行生产和消费动作前的休眠时间，以秒计时；这样做的目的是可以通过调整这一列参数，控制开始进行生产和消费动作的时间。如果是代表生产者，则该行只有三个字段。如果代表消费者，则该行后边还有若干字段，代表要求消费的产品所对应的生产者的线程号。所以务必确认这些对应的线程号存在并且该线程代表一个生产者。
（2）生产和消费的规则
在按照上述要求创建线程进行相应的读写操作时，还需要符合以下要求：
①共享缓冲区存在空闲空间时，生产者即可使用共享缓冲区。
②从上边的测试数据文件例子可以看出，某一生产者生产一个产品后，可能不止一个消费者，或者一个消费者多次地请求消费该产品。此时，只有当所有的消费需求都被满足以后，该产品所在的共享缓冲区才可以被释放，并作为空闲空间允许新的生产者使用。
③每个消费者线程的各个消费需求之间存在先后顺序。例如上述测试用例文件包含一行信息“5 C 3 l 2 4”，可知这代表一个消费者线程，该线程请求消费1，2，4号生产者线程生产的产品。而这种消费是有严格顺序的，消费1号线程产品的请求得到满足后才能继续往下请求2号生产者线程的产品。
④要求在每个线程发出读写操作申请、开始读写操作和结束读写操作时分别显示提示信息。
（3）相关基础知识
本实验所使用的生产者和消费者模型具有如下特点：
本实验的多个缓冲区不是环形循环的，也不要求按顺序访问。生产者可以把产品放到目前某一个空缓冲区中。
消费者只消费指定生产者的产品。
在测试用例文件中指定了所有的生产和消费的需求，只有当共享缓冲区的数据满足了所有关于它的消费需求后，此共享缓冲区才可以作为空闲空间允许新的生产者使用。
本实验在为生产者分配缓冲区时各生产者间必须互斥，此后各个生产者的具体生产活动可以并发。而消费者之间只有在对同一产品进行消费时才需要互斥，同时它们在消费过程结束时需要判断该消费对象是否已经消费完毕并清除该产品。
Windows用来实现同步和互斥的实体。在Windows中，常见的同步对象有：信号量(Semaphore)、互斥量(Mutex)、临界段(CriticalSection)等。使用这些对象都分为三个步骤，一是创建或者初始化：接着请求该同步对象，随即进入临界区，这一步对应于互斥量的上锁；最后释放该同步对象，这对应于互斥量的解锁。这些同步对象在一个线程中创建，在其他线程中都可以使用，从而实现同步互斥。
代码片段和文件信息
#include
#include
#include
#include
#include
const int max_linjiequ_num=77;
const int max_thread_num=88;
struct thread
{
int flag; //标记进程是否已执行
int num; //进程号
char p_c;
int time; //进程等待时间
int thread_request[max_thread_num];
int request_num;
};
struct linjiequ
{
int biaoji; //用以标记临界区状态，-1表示该缓冲区为空，1表该缓冲区将被生产者进程使用
int p_num;
};
linjiequ linjiequ[max_linjiequ_num]; //用该数组模拟缓冲区序列
thread thread[max_thread_num];
int thread_num; //实际进程数
int linjiequ_num;
int findposition（）
{
int n;int mutex; //模拟互斥信号量
for（int i=0;i
if（linjiequ[i].biaoji==-1）
{
n=i;
linjiequ[i].biaoji=1;
break;
}
}
return n;
}
bool otherrequest（int n） //判断是否还有对同一产品的消费请求未执行
{
for（int i=0;i
if（thread[i].thread_request[j]==n）
return true;
break;
}
return false;
}
int little（）
{
int f=0;
while（thread[f].flag==1）
{
f++;
}
int a=fl=thread[f].time;
for（int w=0;w
if（thread[w].time
l=thread[w].time;
a=w;
}
}
return a;
}
void produce（）
{
int m=findposition（）;
Sleep（thread[little（）].time*1000）;
cout<
}
void consumer（）
{
int l=thread[little（）].request_num;
for（int i=0;i<=l;i++）
{
if（i
int temp=thread[little（）].thread_request[i]-1;
if（thread[temp].flag==1）
{
cout<
{
cout<<“已无其他消费者消费“<
if（linjiequ[j].p_num==temp+1）
{
linjiequ[j].biaoji=-1;
cout<
}
}
}
else
{
cout<
i=l+1;
}
}
else
thread[little（）].flag=1;
}
}
void main（）
{
//初始化缓冲区
for（int i=0;i
linjiequ[i].biaoji=-1;
}
//初始化线程请求队列，及请求进程的个数
for（int m=0;m
for（int n=0;n
thread[m].request_num=0; //初始化请求进程的个数
thread[m].flag=0;
}
thread_num=5;
linjiequ_num=3;
thread[0].num=1;
thread[0].p_c=‘p‘;
thread[0].time=3;
thread[1].num=2;
thread[1].p_c=‘p‘;
thread[1].time =4;
thread[2].num=3;
thread[2].p_c=‘c‘;
thread[2].time=4;
thread[2].thread_request[属性 大小 日期 时间 名称
----------- --------- ---------- ----- ----
目录 0 2011-06-21 11:32 生产者与消费者\
目录 0 2011-06-21 10:12 生产者与消费者\Debug\
文件 209015 2011-06-21 10:12 生产者与消费者\Debug\p_c.exe
文件 241212 2011-06-21 10:12 生产者与消费者\Debug\p_c.ilk
文件 24080 2011-06-21 10:12 生产者与消费者\Debug\p_c.obj
文件 3621252 2011-06-20 17:08 生产者与消费者\Debug\p_c.pch
文件 1082368 2011-06-21 10:12 生产者与消费者\Debug\p_c.pdb
文件 197632 2011-06-21 10:50 生产者与消费者\Debug\vc60.idb
文件 143360 2011-06-21 10:12 生产者与消费者\Debug\vc60.pdb
文件 4380 2008-12-14 20:52 生产者与消费者\produce_consume.dsp
文件 538 2008-12-14 20:52 生产者与消费者\produce_consume.dsw
文件 50176 2011-06-20 16:37 生产者与消费者\produce_consume.ncb
文件 48640 2011-06-20 16:37 生产者与消费者\produce_consume.opt
文件 921 2008-12-14 21:10 生产者与消费者\produce_consume.plg
文件 4411 2011-06-21 10:12 生产者与消费者\p_c.cpp
文件 3365 2011-06-21 08:47 生产者与消费者\p_c.dsp
文件 514 2011-06-21 11:32 生产者与消费者\p_c.dsw
文件 50176 2011-06-21 11:32 生产者与消费者\p_c.ncb
文件 48640 2011-06-21 11:32 生产者与消费者\p_c.opt
文件 240 2011-06-21 10:50 生产者与消费者\p_c.plg
川公网安备 51152502000135号
评论
共有 条评论