多线程生产者消费者问题

1、实验报告专业 网络工程 班级 08102班 学号 01号 姓名 胡双双课程名称操作系统 学年20102011 学期 下课程类别专业必修 限选任选实践实验时间 2010年11 月 3 日实验名称实验一：生产者与消费者问题实验目的和要求全面理解生产者与消费者问题模型，掌握解决该问题的算法思想，正确使用同步机制。实验软硬件要求Pentium(R) Dual-Core CPU 1.96G内存WINDOWS XP ProfessionalVisual C+6.0实验内容、方法和步骤（可附页）问题描述：一组生产者向一组消费者提供商品，共享一个有界缓冲池，生产者向其中放入商品，消费者从中取得商品。假定这些生

2、产者和消费者互相等效，只要缓冲池未满，生产者可将商品送入缓冲池；只要缓冲池未空，消费者可从缓冲池取走一商品。功能要求：根据进程同步机制，编写一个解决上述问题的程序，可显示缓冲池状态、放商品、取商品等过程。具体参数：有1个生产者进程； 有1个消费者进程； 缓冲区单元个数BUFFER_NUM =5；不同的生产进程可生产不同的产品，自己可任意定义，在本程序中是直接将相应生产者代号放入缓冲区，消费时将某消费者消费某生产者的信息显示出来实验结果：见截图小结 从此次试验中，学到了很多关于编程的知识，以前对于编程的认识只停留在一些简单的算法上，并没有系统的进行编程训练。此次的试验是以前从没接触过的多线程，中

3、间涉及的同步及互斥问题，在设计软件及系统时，都是极其重要的。 多线程实验对于我们现阶段确实有点偏难，不过，在经过请教同学及看参考书，终于自己写出了一个相对于简单一点的生产者消费者的多线程程序。评定成绩：批阅教师： 年月日 一、问题概述一组生产者向一组消费者提供消息，它们共享一个有界缓冲池，生产者向其中投放消息，消费者从中取得消息。假定这些生产者和消费者互相等效，只要缓冲池未满，生产者可将消息送入缓冲池；只要缓冲池未空，消费者可从缓冲池取走一个消息。二、设计流程图（1）生产者流程图：阻塞为空无空缓冲区否空缓冲区是结 束 解 锁缓冲区已满，请等待生产者生产产品 放入缓冲区对缓冲区加锁（2）消费者流

4、程图阻塞为空无满缓冲区否满缓冲区是结 束 解 锁没有产品可消费，请等待消费者消费缓冲区内的产品对缓冲区加锁三、数据定义# define BUFFER_NUM 5 / 缓冲区个数int mutexBUFFER_NUM=0,0,0,0,0;int bufferBUFFER_NUM=0,0,0,0,0;/初始化缓冲区为空HANDLE g_hMutex; /用于线程间的互斥 void show()；/函数，显示生产者及消费者过程DWORD WINAPI Producer(LPVOID lpPara)；/过程，生产者生产产品过程DWORD WINAPI Customer(LPVOID lpPara)；/

5、 过程，消费者消费产品过程四、源程序#include#include# define BUFFER_NUM 5 / 缓冲区个数int mutexBUFFER_NUM=0,0,0,0,0;int bufferBUFFER_NUM=0,0,0,0,0;/初始化缓冲区为空HANDLE g_hMutex; /用于线程间的互斥 void show()for(int i=0;iBUFFER_NUM;i+)printf(第%d个缓冲区为：%dn,i,bufferi);printf(n-n);DWORD WINAPI Producer(LPVOID lpPara)while(true)for(int i=0;

6、iBUFFER_NUM;i+)if(bufferi=0) if(mutexi=0)mutexi=1;/加锁 WaitForSingleObject(g_hMutex,INFINITE); bufferi=1;printf(生产出一个产品，已放入第%d个缓冲区n,i);show(); Sleep(1000); ReleaseMutex(g_hMutex); mutexi=0;/解锁break; if(i=BUFFER_NUM)printf(缓冲区已满，请等待n); /缓冲区已满，请等待 Sleep(1000); DWORD WINAPI Customer(LPVOID lpPara)while(

7、true)for(int j=0;jBUFFER_NUM;j+)if(bufferj=1) if(mutexj=0)mutexj=1;/加锁WaitForSingleObject(g_hMutex,INFINITE); bufferj=0;printf(消费者已消费第%d个缓冲区的产品n,j);show(); Sleep(1000);ReleaseMutex(g_hMutex); mutexj=0;/解锁 break; if(j=BUFFER_NUM)printf(没有产品可消费，请等待n); /没有产品可消费，请等待 Sleep(1000);int main(int argc,char* argv)HANDLE handle4;g_hMutex = CreateMutex(NULL,FALSE,NULL); for(int i=0;i2;i+)handlei=CreateThread(NULL,0,Producer,NULL,0,NULL);for(i=2;i4;i+)handlei=CreateThread(NUL