操作系统生产者与消费者专业课程设计.doc

操作系统课程设计生产者和消费者问题系 院：计算机科学系学生姓名：吴伟学 号：专 业：软件工程年 级：0701B完毕日期：11月指引教师：刘栓一、课程设计性质与任务1、生产者-消费者问题是很典型很具备代表性进程同步问题，计算机中诸多同步问题都可抽象为生产者-消费者问题，通过本实验练习，但愿能加深学生对进程同步问题结识与理解。2、熟悉VC使用，培养和提高学生分析问题、解决问题能力。二、课程设计内容及其规定1 实验内容以生产者/消费者模型为根据，在Windows 环境下创立一种控制台进程，在该进程中创立n个线程模仿生产者和消费者，实现进程(线程)同步与互斥。2 实验规定l 学习并理解生产者/消费者模型及其同步/互斥规则；l 学习理解Windows同步对象及其特性；l 熟悉实验环境，掌握有关API用法；l 设计程序，实现生产者/消费者进程(线程)同步与互斥；l 提交实验报告。三、课程设计时间安排课程设计时间 8学时四、课程设计实验环境本实验是在winxpVC6.0环境下实现，运用Windows SDK编制实例程序。因此实验需要在windows下安装VC后进行。VC是一种集成开发环境，其中包括了Windows SDK所有工具和定义；因此安装了VC后就不用特意安装SDK了。五、正文1、 实验程序构造图（流程图）；开始ProduceWait BufferWait ProductsConsume结束While produceWhile consume2、数据构造及信号量定义阐明；(1) CreateThreadl 功能创立一种在调用进程地址空间中执行线程l 格式HANDLE CreateThread( LPSECURITY_ATTRIBUTES lpThreadAttributes,DWORD dwStackSize,LPTHREAD_START_ROUTINE lpStartAddress,LPVOID lpParamiter,DWORD dwCreationFlags,Lpdword lpThread );l 参数阐明lpThreadAttributes指向一种LPSECURITY_ATTRIBUTES(新线程安全性描述符)。dwStackSize定义原始堆栈大小。lpStartAddress指向使用LPTHRAED_START_ROUTINE类型定义函数。lpParamiter定义一种给进程传递参数指针。dwCreationFlags定义控制线程创立附加标志。lpThread保存线程标志符(32位)(2) CreateMutexl 功能创立一种命名或匿名互斥量对象l 格式HANDLE CreateMutex(LPSECURITY_ATTRIBUTES lpMutexAttributes,BOOL bInitialOwner,LPCTSTR lpName);l 参数阐明lpMutexAttributes必要取值NULL。bInitialOwner批示当前线程与否立即拥有该互斥量(即立即加锁)。lpName互斥量名称。(3) CreateSemaphorel 功能创立一种命名或匿名信号量对象l 格式HANDLE CreateSemaphore(LPSECURITY_ATTRIBUTES lpSemaphoreAttributes, LONG lInitialCount, LONG lMaximumCount, LPCTSTR lpName );l 参数阐明lpSemaphoreAttributes必要取值NULL。lInitialCount信号量初始值。该值不不大于0，但不大于lMaximumCount指定最大值。lMaximumCount信号量最大值。lpName信号量名称。(4) WaitForSingleObjectl 功能使程序处在等待状态，直到信号量hHandle浮现(即其值不不大于等于1)或超过规定等待时间l 格式DWORD WaitForSingleObject(HANDLE hHandle，DWORD dwMilliseconds);l 参数阐明hHandle信号量指针。dwMilliseconds等待最长时间(INFINITE为无限等待)。(5) ReleaseSemaphorel 功能对指定信号量加上一种指定大小量。成功执行则返回非0值l 格式BOOL ReleaseSemaphore(HANDLE hSemaphore,LONG lReleaseCount,LPLONG lppreviousCount );l 参数阐明hSemaphore信号量指针。lReleaseCount信号量增量。lppreviousCount保存信号量当前值。(6) ReleaseMutexl 功能打开互斥锁，即把互斥量加1。成功调用则返回0l 格式BOOL ReleaseMutex(HANDLE hMutex);l 参数阐明hMutex互斥量指针。(7) InitializeCriticalSectionl 功能初始化临界区对象l 格式VOID InitializeCriticalSection(LPCRITICAL_SECTION lpCriticalSection);l 参数阐明lpCriticalSection指向临界区对象指针。(8) EnterCriticalSectionl 功能等待指定临界区对象所有权l 格式VOID enterCriticalSection(LPCRITICAL_SECTION lpCriticalSection);l 参数阐明lpCriticalSection指向临界区对象指针。(9) LeaveCriticalSectionl 功能释放指定临界区对象所有权l 格式VOID LeaveCriticalSection(LPCRITICAL_SECTION lpCriticalSection);l 参数阐明lpCriticalSection指向临界区对象指针。3、实验环节；(1) 打开VC，选取菜单项file-new,选取projects选项卡并建立一种名为 R_WP1win32 console applicatoin工程；创立时注意指定创立该工程目录；(2) 在工程中创立源文献 R_WP1.cpp：选取菜单项project-add to project-files，在选取框中输入自己想要创立文献名，这里是 R_WP1.cpp；在接下来询问与否创立新文献时回答yes；然后通过Workspace-FileView-Source Files打开该文献，在其中编辑源文献并保存.(3) 通过调用菜单命令项build-build all进行编译连接,可以在指定工程目录下得到debug- R_WP1.exe程序，然后把给定test.txt文献存入该debug目录下，就可以在控制台进入该debug目录运营程序了。需要强调是在创立数据文献时，由于涉及到文献格式问题，最佳在记事本中手工逐个输入数据，而不要拷贝粘贴数据。4、重要算法创立生产者和消费者线程for(i =0;iserial;m_delay = (DWORD)(ThreadInfo*)(p)-delay *INTE_PER_SEC);Sleep(m_delay);/开始祈求生产printf(Producer %2d sends the produce require.n,m_serial);/确认有空缓冲区可供生产，同步将空位置数empty减1；用于生产者和消费者同步；wait_for_semaphore= WaitForSingleObject(empty_semaphore,-1);/互斥访问下一种可用于生产空临界区，实现写写互斥；wait_for_mutex = WaitForSingleObject(h_mutex,-1);int ProducePos = FindProducePosition(); ReleaseMutex(h_mutex);/生产者在获得自己空位置并做上标记后，如下写操作在生产者之间可以并发；/核心生产环节中，程序将生产者ID作为产品编号放入，以便消费者辨认;printf(Producer %2d begin to produce at position %2d.n,m_serial,ProducePos);Buffer_CriticalProducePos = m_serial;printf(Producer %2d finish producing :n ,m_serial);printf( position %2d :%3d n ,ProducePos,Buffer_CriticalProducePos);/使生产者写缓冲区可以被各种消费者使用，实现读写同步；ReleaseSemaphore(h_Semaphorem_serial,n_Thread,NULL);消费者进程void Consume(void * p)/局部变量声明；DWORDwait_for_semaphore,m_delay;intm_serial,m_requestNum; /消费者序列号和祈求数目；intm_thread_requestMAX_THREAD_NUM;/本消费线程祈求队列； /提取本线程信息到本地；m_serial = (ThreadInfo*)(p)-serial;m_delay = (DWORD)(ThreadInfo*)(p)-delay *INTE_PER_SEC);m_requestNum = (ThreadInfo *)(p)-n_request;for (int i = 0;ithread_requesti;Sleep(m_delay);/循环进行所需产品消费for(i =0;ithread_requesti =-1; if(!IfInOtherRequest(m_thread_requesti)Buffer_CriticalBufferPos = -1； /标记缓冲区为空；printf(Consumer%2d finish consuming %2d:n ,m_serial,m_thread_requesti);printf( position %2d :%3d n ,BufferPos,Buffer_CriticalBufferPos);ReleaseSemaphore(empty_semaphore,1,NULL); elseprintf(Consumer %2d finish consuming product %2dn ,m_serial,m_thread_requesti); /离开临界区 LeaveCriticalSection(&PC_CriticalBufferPos); 5、实验运营图；6、实验成果分析；只有在生产者生产了产品并将产品存储到缓冲池中消费者才干去消费，当缓冲池为空时消费者不能消费六、 结论（应当精确、完整、明确精练；也可以在结论或讨论中提出建议、设想、尚待解决问题等。）七、 参照文献【1】汤子瀛等.计算机操作系统.西安电子科技大学出版社.2月【2】张尧学等编著，计算机操作系统教程，清华出版社。.2【3】严蔚敏，吴伟民编著，数据构造，清华大学出版社。【4】陈向群编著，操作系统教程，北京大学出版社，.07【5】郑莉等编著，C+语言设计。北京：清华大学出版社.八、 指引教师评语 签名： 年 月 日课程设计成绩附：课程设计源代码：#include#include#include#include#include/定义常量；/此程序容许最大临界区数；#define MAX_BUFFER_NUM10/秒到微秒乘法因子；#define INTE_PER_SEC 1000/本程序容许生产和消费线程总数；#define MAX_THREAD_NUM 64/定义一种构造，记录在测试文献中指定每一种线程参数struct ThreadInfointserial;/线程序列号charentity; /是P还是Cdoubledelay;/线程延迟intthread_requestMAX_THREAD_NUM；/线程祈求队列intn_request;/祈求个数;/全局变量定义/临界区对象声明,用于管理缓冲区互斥访问；CRITICAL_SECTIONPC_CriticalMAX_BUFFER_NUM;int Buffer_CriticalMAX_BUFFER_NUM；/缓冲区声明，用于存储产品；HANDLE h_ThreadMAX_THREAD_NUM; /用于存储每个线程句柄数组；ThreadInfoThread_InfoMAX_THREAD_NUM; /线程信息数组；HANDLEempty_semaphore; /一种信号量；HANDLEh_mutex; /一种互斥量；DWORDn_Thread = 0; /实际线程数目；DWORDn_Buffer_or_Critical; /实际缓冲区或者临界区数目；HANDLEh_SemaphoreMAX_THREAD_NUM；/生产者容许消费者开始消费信号量；/生产消费及辅助函数声明void Produce(void *p);void Consume(void *p);bool IfInOtherRequest(int);int FindProducePositon();int FindBufferPosition(int);int main(void)/声明所需变量；DWORDwait_for_all;ifstreaminFile;/初始化缓冲区；for(int i=0;i MAX_BUFFER_NUM;i+)Buffer_Criticali = -1;/初始化每个线程祈求队列；for(int j=0;jMAX_THREAD_NUM;j+)for(int k=0;kMAX_THREAD_NUM;k+)Thread_Infoj.thread_requestk = -1;Thread_Infoj.n_request = 0;/初始化临界区；for(i =0;i n_Buffer_or_Critical;inFile.get();printf(输入文献是:n);/回显获得缓冲区数目信息；printf(%d n,(int) n_Buffer_or_Critical);/提取每个线程信息到相应数据构造中；while(inFile)inFile Thread_Infon_Thread.serial;inFile Thread_Infon_Thread.entity;inFile Thread_Infon_Thread.delay;char c;inFile.get(c);while(c!=n& !inFile.eof() inFile Thread_Infon_Thread.thread_requestThread_Infon_Thread.n_request+; inFile.get(c);n_Thread+; /回显获得线程信息，便于确认对的性；for(j=0;j(int) n_Thread;j+)int Temp_serial = Thread_Infoj.serial;char Temp_entity = Thread_Infoj.entity;double Temp_delay = Thread_Infoj.delay;printf( n thread%2d %c %f ,Temp_serial,Temp_entity,Temp_delay);int Temp_request = Thread_Infoj.n_request;for(int k=0;kTemp_request;k+)printf( %d ，Thread_Infoj.thread_requestk);coutendl;printf(nn); /创立在模仿过程中几种必要信号量empty_semaphore=CreateSemaphore(NULL,n_Buffer_or_Critical,n_Buffer_or_Critical, semaphore_for_empty);h_mutex= CreateMutex(NULL,FALSE,mutex_for_update);/下面这个循环用线程ID号来为相应生产线程产品读写时所/使用同步信号量命名；for(j=0;j(int)n_Thread;j+) std:string lp =semaphore_for_produce_;int temp =j;while(temp)char c = (char)(temp%10);lp+=c;temp/=10;h_Semaphorej+1=CreateSemaphore(NULL,0,n_Thread,lp.c_str();/创立生产者和消费者线程；for(i =0;i (int) n_Thread;i+)if(Thread_Infoi.entity =P)h_Threadi= CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(Produce),&(Thread_Infoi),0,NULL);else h_Threadi=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(Consume),&(Thread_Infoi),0,NULL);/主程序等待各个线程动作结束；wait_for_all = WaitForMultipleObjects(n_Thread,h_Thread,TRUE,-1);printf( n nALL Producer and consumer have finished their work. n);getch();return 0;/确认与否尚有对同一产品消费祈求未执行；bool IfInOtherRequest(int req)for(int i=0;in_Thread;i+)for(int j=0;jThread_Infoi.n_request;j+)if(Thread_Infoi.thread_requestj = req)return TRUE;return FALSE;/找出当前可以进行产品生产空缓冲区位置；intFindProducePosition()int EmptyPosition;for (int i =0;in_Buffer_or_Critical;i+)if(Buffer_Criticali = -1)EmptyPosition = i;/用下面这个特殊值表达本缓冲区正处在被写状态；Buffer_Criticali = -2;break;return EmptyPosition;/找出当前所需生产者生产产品位置；int FindBufferPosition(int ProPos)int TempPos;for (int i =0 ;iserial;m_delay = (DWORD)(ThreadInfo*)(p)-delay *INTE_PER_SEC);Sleep(m_delay);/开始祈求生产printf(Producer %2d sends the produce require.n,m_serial);/确认有空缓冲区可供生产，同步将空位置数empty减1；用于生产者和消费者同步；wait_for_semaphore= WaitForSingleObject(empty_semaphore,-1);/互斥访问下一种可用于生产空临界区，实现写写互斥；wait_for_mutex = WaitForSingleObject(h_mutex,-1);int ProducePos = FindProducePosition(); ReleaseMutex(h_mutex);/生产者在获得自己空位置并做上标记后，如下写操作在生产者之间可以并发；/核心生产环节中，程序将生产者ID作为产品编号放入，以便消费者辨认;printf(Producer %2d begin to produce at position %2d.n,m_serial,ProducePos);Buffer_CriticalProducePos = m_serial;printf(Producer %2d finish producing :n ,m_serial);printf( position %2d :%3d n ,ProducePos,Buffer_CriticalProducePos);/使生产者写缓冲区可以被各种消费者使用，实现读写同步；ReleaseSemaphore(h_Semaphorem_serial,n_Thread,NULL);/消费者进程void Consume(void * p)/局部变量声明；DWORDwait_for_semaphore,m_delay;intm_serial,m_requestNum; /消费者序列号和祈求数目；intm_thread_requestMAX_THREAD_NUM;/本消费线程祈求队列； /提取本线程信息到本地；m_serial = (ThreadInfo*)(p)-serial;m_delay = (DWORD)(ThreadInfo*)(p)-delay *INTE_PER_SEC);m_requestNum = (ThreadInfo *)(p)-n_request;for (int i = 0;ithread_requesti;Sleep(m_delay);/循环进行所需产品消费for(i =0;ithread_requesti =-1; if(!IfInOtherRequest(m_thread_requesti)Buffer_CriticalBufferPos = -1； /标记缓冲区为空；printf(Consumer%2d finish consuming %2d:n ,m_serial,m_thread_requesti);printf( position %2d :%3d n ,BufferPos,Buffer_CriticalBufferPos);ReleaseSemaphore(empty_semaphore,1,NULL); elseprintf(Consumer %2d finish consuming product %2dn ,m_serial,m_thread_requesti); /离开临界区 LeaveCriticalSection(&PC_CriticalBufferPos);