OS课设读者和写者.doc

武汉理工大学计算机操作系统课程设计说明书学 号： 课 程 设 计题 目进程同步模拟设计读者和写者问题学 院专 业班 级姓 名指导教师2012年1月11日课程设计任务书学生姓名： 专业班级： 指导教师： 工作单位： 题 目: 进程同步模拟设计读者和写者问题 初始条件：1预备内容：阅读操作系统的进程管理章节内容，对进程的同步和互斥，以及信号量机制度有深入的理解。2实践准备：掌握一种计算机高级语言的使用。要求完成的主要任务: （包括课程设计工作量及其技术要求，以及说明书撰写等具体要求）1模拟用信号量机制实现读者和写者问题。2设计报告内容应说明： 课程设计目的与功能； 需求分析，数据结构或模块说明(功能与框图)； 源程序的主要部分； 测试用例，运行结果与运行情况分析； 自我评价与总结：i）你认为你完成的设计哪些地方做得比较好或比较出色；ii）什么地方做得不太好，以后如何改正；iii）从本设计得到的收获（在编写，调试，执行过程中的经验和教训）；iv）完成本题是否有其他的其他方法（如果有，简要说明该方法）；v）对实验题的评价和改进意见，请你推荐设计题目。时间安排：设计安排一周：周1、周2：完成程序分析及设计。周2、周3：完成程序调试及测试。周4、周5：验收、撰写课程设计报告。（注意事项：严禁抄袭，一旦发现，抄与被抄的一律按0分记）指导教师签名： 年 月 日系主任（或责任教师）签名： 年 月 日目录1 设计概.12 设计目的与内容.22.1 设计目的.32.2 设计内容.33 设计分析.34 源程序的主要部分及流程图.44.1 源程序主要部分.44.2 程序流程图.45 测设用例和运行结果.55.1 测试用例.55.2 运行结果.55.3 运行结果分析.66 自我评价与总结.77 参考文献.78 源程序.8本科生课程设计成绩评定表.14151 设计概述所谓读者写者问题,是指保证一个 writer 进程必须与其他进程互斥地访问共享资源的同步问题.读者写者问题可以这样的描述,有一群写者和一群读者, 写者在写同一本书,读者也在读这本书,多个读者可以同时读这本书,但是只能有一个写者在写书,并且读者优先,也就是说,读者和写者同时提出请求时,读者优先.当读者提出请求时需要有一个互斥操作, 另外需要有一个信号量 mutex来当前是否可操作.信号量机制是支持多道程序的并发操作系统设计中解决资源共享时进程间的同步与互斥的重要机制,而读者写者问题则是这一机制的一个经典范例. 与记录型信号量解决读者写者问题不同,信号量机制它增加了一个限制,即最多允许n个读者同时读.为此引入了一个信号量Rcount,并赋予初值为 0,通过执行Rcount+操作,来控制读者的数目,每当有一个读者进入时,就要执行Rcount+操作,使 Rcount 的值加1.读者离开时Rcount-;当且仅当Rcount=0时，V（Wmutex），才能进行写操作。对利用信号量来解决读者写者问题的描述如下:Wmutex表示读写的互斥信号量，初值：Wmutex =1； 公共变量Rcount表示“正在读”的进程数，初值：Rcount =0； Rmutex：表示对Rcount的互斥操作，初值：Rmutex=1。main()int Wmutex=1;int Rmutex=1;int Rcount=0;cobeginread 1();read 2();read 3();.write 1();write2 ();write3 ();.coendreadn()P(Rmutex);Rcount+;if (Rcount=1) P (Wmutex);V(Rmutex);读P(Rmutex);Rcount-;if (Rcount=0)V(Wmutex);V(Rmutex);writen()P(Wmutex);写V(Wmutex); 2 设计目的与内容2.1 设计目的 l. 用信号量来实现读者写者问题. 2 .理解和运用信号量,PV 原语,进程间的同步互斥关系等基本知识. 2.2设计内容 读者写者问题的定义如下:有一个许多进程共享的数据区,这个数据区可以 是一个文件或者主存的一块空间;有一些只读取这个数据区的进程(Reader)和 一些只往数据区写数据的进程(Writer),此外还需要满足以下条件:(1) 任意多个读进程可以同时读这个文件;(2)一次只有一个写进程可以往文件中写; (3)如果一个写进程正在进行操作,禁止任何读进程度文件.我们需要分两种情况实现该问题: 读优先:要求指一个读者试图进行读操作时,如果这时正有其他读者在进行操作,他可直接开始读操作,而不需要等待. 写优先:一个读者试图进行读操作时,如果有其他写者在等待进行写操作或 正在进行写操作,他要等待该写者完成写操作后才开始读操作. 3设计分析在 Windows xp 环境下,创建一个包含 n 个线程的控制台进程.用这 n 个线程来表示 n 个读者或写者. 每个线程按相应测试数据文件的要求, 进行读写操作. 请用信号量机制分别实现读者优先和写者优先的读者-写者问题. 读者-写者问题的读写操作限制: 读者-写者的读写限制(包括读者优先和写者优先) 1)写-写互斥,即不能有两个写者同时进行写操作 2)读-写互斥,即不能同时有一个读者在读,同时却有一个写者在写 3)读读允许,即可以有 2 个以上的读者同时读将所有的读者和所有的写者分别放进两个等待队列中, 当读允许时就让读者 队列释放一个或多个读者,当写允许时,释放第一个写者操作.读者写者问题的 定义如下:有一个许多进程共享的数据区,这个数据区可以是一个文件或者主存 的一块空间;有一些只读取这个数据区的进程(Reader)和一些只往数据区写数 据的进程(Writer),此外还需要满足以下条件:1)任意多个读进程可以同时读这 个文件;2) 一次只有一个写进程可以往文件中写;3)如果一个写进程正在进行操作,禁止任何读进程度文件.4 源程序的主要部分及流程图4.1源程序主要部分结构体_Person如下typedef struct _Person HANDLE m_hThread;/定义处理线程的句柄 int m_nType;/进程类型(读写) int m_nStartTime;/开始时间 int m_nWorkTime;/运行时间 int m_nID;/进程号 Person;main()函数（主线程）创建信号灯,当前可用的资源数为 1,最大为 100 ：g_hReadSemaphore = CreateSemaphore(NULL,1,100,NULL)g_hWriteSemaphore = CreateSemaphore(NULL,1,100,NULL)调用CreatePersonList()函数，设置线程同步间隔为1000ms，计算时间片。CreatePersonList(int *pPersonLists)函数根据*pPersonLists队列创建读者/写者。CreateReader(int StartTime,int WorkTime,int ID)函数创建与读者有关的线程，并初始化g_Persons g_NumPersonCreateWriter(int StartTime,int WorkTime,int ID)函数创建与写者有关的线程，并初始化g_Persons g_NumPerson DWORD WINAPI ReaderProc(LPVOID lpParam)和DWORD WINAPI WriterProc(LPVOID lpParam)分别与读者和写者对应的辅助线程函数。4.2程序流程图CreatePersonList()CreateWriter()CreateReader()WriterProc（）ReaderProc（）退出WRMain()5 测试用例和运行结果5.1测试用例int g_PersonLists = 1, W,1,3,2, W,3,1, 3, R,10,2, 4, W,6,3, 5, R,7,5,6, R,9,1, END, ; 5.2运行结果5.3运行结果分析进程1是写操作，在时间片1进入队列，运行时间3，在它进入时没有进程占用资源，立即占用资源，直到释放资源。在它占用资源时等待的进程有：2进程2是写操作，在时间片3进入队列，运行时间1，由于进程1在占用资源，所以等待进程1释放资源。在它占用资源时没有等待的进程进程3是读操作，在时间片10进入队列，运行时间2，此时读者5在占用资源，但由于可以多个读者同时阅读，所以读者3也可以阅读进程4是写操作，在时间片6进入队列，运行时间3，此时没有进程占用资源，它可以立即占用资源，直到结束并释放资源。在它占用资源时等待的进程有：5,6进程5是读操作，在时间片7进入队列，运行时间5，由于此时进程4在占用资源，所以等待进程4释放资源。进程6是读操作，在时间片9进入队列，运行时间1，由于此时进程4在占用资源，所以等待进程4释放资源。由于可以多个读者同时阅读，所以读者3,5,6在时间片10同时阅读。6自我评价与总结这一次课程设计,让我体会很深刻.总的感觉,学到了很多知识,读者-写者问题经典的线程同步问题的一个模型.经过读者写者问题的编写,我对同步机构应用有了深入的了解.懂得了运用信号量实现进程间的同步互斥.用信号量上的原语操作使临界段问题的解决比较简单明了.读者写者问题的编写,花的时间很多,也学到很多东西.了解C/C+多线程的并发设计.几天的试验,虽然难度有点大,但只要自己花时间去学习,还是会攻克困难的.但这次课设还是有不完美的地方。没有考虑读者优先/写者优先两种不同的情况。在网上查询资料时看到别人有考虑这两种情况，而我自己只是根据老师上课所讲的内容进行编程，只有读者优先。除此以外，我感觉自己的编程水平仍然有待提高，因为本次课设需要用到进程/线程方面的知识，而这些知识我以前几乎是没有接触过的，花了整整一天的时间才稍微把它弄明白。不得不说，我的编程知识还是很狭窄，需要不断加强学习。我个人觉得课设的题目很适合我们。因为这些题目都是上课内容。在做课设的同时我们还能复习课本知识，一举两得。但课设的要求感觉不是很清晰，比如说，要用什么语言编写（java/c+/c），要求的基本效果等等。总之,每一次课程设计不仅是我们学习的好机会,而且是我们锻炼实际动手能力的平台,虽然有难度的东西总会让人很抵触,比如在课设过程中有时候一个小小的错误一不小心就花去了自己好几个小时的时间,所以在这个过程中能够磨练人的意志与耐心,最后感谢老师的指导与监督.7参考文献1C+编程设计教程闵联营 何克右 主编；武汉理工大学出版社2005年2计算机操作系统教程张尧学 史美林 张高 编著；清华大学出版2006年3Visual C+从初学到精通吕兵 曲宝军 王玮等编著；电子工业出版社2010年 8源程序#include #include #include #include #include #include #define MAX_PERSON 100#define READER 0/读者#define WRITER 1 /写者#define END -1#define R READER#define W WRITER typedef struct _Person HANDLE m_hThread;/定义处理线程的句柄 int m_nType;/进程类型(读写) int m_nStartTime;/开始时间 int m_nWorkTime;/运行时间 int m_nID;/进程号Person; Person g_PersonsMAX_PERSON; int g_NumPerson = 0;long g_CurrentTime= 0;/基本时间片数 int g_PersonLists = 1, W,1,3,2, W,3,1, 3, R,10,2, 4, W,6,3, 5, R,7,5,6, R,9,1, END, ; /队列int g_NumOfReading = 0; int g_NumOfWriteRequest = 0;/申请写进程的个数HANDLE g_hReadSemaphore;/读者信号 HANDLE g_hWriteSemaphore;/写者信号 bool finished = false; /所有的读完成bool wfinished = false; /所有的写完成 void CreatePersonList(int *pPersonList);bool CreateReader(int StartTime,int WorkTime,int ID); bool CreateWriter(int StartTime,int WorkTime,int ID);DWORD WINAPI ReaderProc(LPVOID lpParam); DWORD WINAPI WriterProc(LPVOID lpParam);int main() g_hReadSemaphore = CreateSemaphore(NULL,1,100,NULL); /创建信号灯,当前可用的资源数为 1,最大为 100 g_hWriteSemaphore = CreateSemaphore(NULL,1,100,NULL); /创建信号灯,当前 可用的资源数为 1,最大为 100 printf(开始.n);CreatePersonList(g_PersonLists); /创建读者与写者 g_CurrentTime = 0; while(true) g_CurrentTime+; Sleep(500);printf(时间片 = %dn,g_CurrentTime); if(finished) return 0; return 0; void CreatePersonList(int *pPersonLists) int i=0; int *pList = pPersonLists; bool Ret; while(pList0 != END) switch(pList1) case R: Ret = CreateReader(pList2,pList3,pList0);break; case W: Ret = CreateWriter(pList2,pList3,pList0); break; if(!Ret) printf(创建 %d 失败n,pList0); pList += 4; / move to next person list DWORD WINAPI ReaderProc(LPVOID lpParam)/读过程 Person *pPerson = (Person*)lpParam; while(g_CurrentTime != pPerson-m_nStartTime) / 等待开始 printf(读者 %d 正在申请资源 .n,pPerson-m_nID); WaitForSingleObject(g_hReadSemaphore,INFINITE);/ 等待对象被触发信号if(g_NumOfReading =0) WaitForSingleObject(g_hWriteSemaphore,INFINITE);g_NumOfReading+; ReleaseSemaphore(g_hReadSemaphore,1,NULL); pPerson-m_nStartTime = g_CurrentTime; printf(读者 %d 正在阅读.n,pPerson-m_nID); while(g_CurrentTime m_nStartTime + pPerson-m_nWorkTime) printf(读者 %d 正在退出.n,pPerson-m_nID); WaitForSingleObject(g_hReadSemaphore,INFINITE);g_NumOfReading-; if(g_NumOfReading = 0) ReleaseSemaphore(g_hWriteSemaphore,1,NULL);/此时没有读者,可以写 ReleaseSemaphore(g_hReadSemaphore,1,NULL); if(pPerson-m_nID = 4) finished = true; /所有的读写完成 ExitThread(0); return 0; DWORD WINAPI WriterProc(LPVOID lpParam) Person *pPerson = (Person*)lpParam; while(g_CurrentTime != pPerson-m_nStartTime) / 等待开始 printf(写者 %d 正在申请资源.n,pPerson-m_nID); WaitForSingleObject(g_hWriteSemaphore,INFINITE); / 等待对象被触发信号pPerson-m_nStartTime = g_CurrentTime; printf(写者 %d 正在写入.n,pPerson-m_nID); while(g_CurrentTime m_nStartTime + pPerson-m_nWorkTime) printf(写者 %d 正在退出.n,pPerson-m_nID); g_NumOfWriteRequest-; ReleaseSemaphore(g_hWriteSemaphore,1,NULL); if(pPerson-m_nID = 4) finished = true;/所有的读写完成ExitThread(0); return 0; bool CreateReader(int StartTime,int WorkTime,int ID) if(g_NumPerson = MAX_PERSON) return false; Person *pPerson = &g_Personsg_NumPerson; pPerson-m_nID = ID;