读者写者问题课程设计报告

1、操作系统课程设计报告题目：读者写者问题信息工程学院专业：计算机科学与技术班级：080412学号： 08041238姓名：胡江红2010年12月24日一设计概述 3二设计目的与内容 4三设计分析5四程序实现6五程序调试7六结果分析和讨论 7七心得体会8八源代码8设计概述所谓读者写者问题，是指保证一个 writer 进程必须与其他进程互斥地访问共 享对象的同步问题。读者写者问题可以这样的描述， 有一群写者和一群读者， 写者在写同一本书， 读者也在读这本书， 多个读者可以同时读这本书， 但是，只能有一个写者在写书， 并且，读者必写者优先，也就是说，读者和写者同时提出请求时，读者优先。当 读者提出请求

2、时需要有一个互斥操作， 另外，需要有一个信号量 S 来当前是否可 操作。信号量机制是支持多道程序的并发操作系统设计中解决资源共享时进程间 的同步与互斥的重要机制，而读者写者问题则是这一机制的一个经典范例。与记录型信号量解决读者 写者问题不同，信号量机制它增加了一个限制， 即最多允许RN个读者同时读。为此，又引入了一个信号量L,并赋予初值为RN , 通过执行wait（ L,1,1）操作，来控制读者的数目，每当有一个读者进入时，就要 执行wait（ L,1,1）操作，使L的值减1。当有RN个读者进入读后，L便减为0， 第RN+1个读者要进入读时，必然会因 wait（ L,1,1）操作失败而堵塞。对

3、利用 信号量来解决读者 写者问题的描述如下：Var RN integer;L,mx:semaphore: =RN,1；BeginParbeginReader :beginRepeatSwait（L,1,1） ;Swait（mx,1,0） ;Perform reader operation;Ssignal（L,1）;Until false;EndWriter ： beginRepeatSwait(mx ,1,1,l,RN,0);Perform writer operation;Ssignal(mx,1);Until false;EndParendEnd其中，Swait (mx,1,0)语句起着开

4、关作用，只要无Writer进程进入些，mx=1, reader进程就都可以进入读。但是要一旦有 Writer进程进入写时，其 MX=0，则 任何reader进程就都无法进入读。Swait(mx ,1,1,l,RN,0)语句表示仅当既无 Write 进程在写(mx=1)，又无reader进程在读(L=RN)时，writer进程才能进入临 界区写。本设计方案就是通过利用记录型信号量对读者写者问题的解决过程进行模 拟演示，形象地阐述记录型信号量机制的工作原理。二 设计目的与内容一 实验目的1. 用信号量来实现读者写者问题。2. 理解和运用信号量、PV原语、进程间的同步互斥关系等基本知识。二、二 实验

5、内容读者写者问题的定义如下： 有一个许多进程共享的数据区， 这个数据区可以 是一个文件或者主存的一块空间； 有一些只读取这个数据区的进程 (Reader)和 一些只往数据区写数据的进程 (Writer) ，此外还需要满足以下条件：(1) 任意多个读进程可以同时读这个文件；2）一次只有一个写进程可以往文件中写；（3）如果一个写进程正在进行操作，禁止任何读进程度文件。我们需要分两种情况实现该问题： 读优先：要求指一个读者试图进行读操作时， 如果这时正有其他读者在进行 操作，他可直接开始读操作，而不需要等待。写优先：一个读者试图进行读操作时， 如果有其他写者在等待进行写操作或 正在进行写操作，他要等

6、待该写者完成写操作后才开始读操作。三设计分析在 Windows 7 环境下， 创建一个包含 n 个线程的控制台进程。用这 n 个线 程来表示 n 个读者或写者。每个线程按相应测试数据文件的要求， 进行读写操作。 请用信号量机制分别实现读者优先和写者优先的读者 -写者问题。读者-写者问题的读写操作限制： 读者-写者的读写限制（包括读者优先和写者优先）1）写-写互斥，即不能有两个写者同时进行写操作2）读-写互斥，即不能同时有一个读者在读，同时却有一个写者在写3）读读允许，即可以有 2 个以上的读者同时读 将所有的读者和所有的写者分别放进两个等待队列中， 当读允许时就让读者 队列释放一个或多个读者，

7、 当写允许时， 释放第一个写者操作。 读者写者问题的 定义如下： 有一个许多进程共享的数据区， 这个数据区可以是一个文件或者主存 的一块空间；有一些只读取这个数据区的进程（Reade）和一些只往数据区写数 据的进程（Writer），此外还需要满足以下条件：1）任意多个读进程可以同时读这 个文件； 2） 一次只有一个写进程可以往文件中写； 3）如果一个写进程正在进行 操作，禁止任何读进程度文件。我们需要分两种情况实现该问题：读优先：要求指一个读者试图进行读操作时， 如果这时正有其他读者在进行 操作，他可直接开始读操作，而不需要等待。写优先：一个读者试图进行读操作 时，如果有其他写者在等待进行写操

8、作或正在进行写操作， 他要等待该写者完成 写操作后才开始读操作。四程序实现程序由两部分组成：1。读者-写者模块：包括系统调用接口，读者-写者活动描述主程序。系统接口 主要功能是通过管道向父进程发送系统调用命令，并读取父进程送来的返回值。读者-写者活动程序根据临界资源的共享，互斥原则编制，具体见源程序。2。主控模块：主控模块实现系统初始化系统调用命令接收与解释执行，系统调 用功能的实现（包括信号量机制），及读者-写者活动过程记录与显示。初始化系统环境建立通信管道启动读者-写者进程接收系统调用命令解释执行系统初始化模块管道建立模块进程启动模块命令解释模块Wait()Signal() Wakeup(

9、) Block()五 程序调试测试数据文件格式 :测试数据文件包括 n 行测试数据，分别描述创建的 n 个线程是读者还是写 者，以及读写操作的开始时间和持续时间。 每行测试数据包括四个字段， 各字段 间用空格分隔。 第一字段为一个正整数， 表示线程序号。 第二字段表示相应线程 角色， R 表示读者是， W 表示写者。第三字段为一个正数，表示读写操作的开 始时间。线程创建后，延时相应时间（单位为秒） 后发出对共享资源的读写申请。 第四字段为一个正数， 表示读写操作的持续时间。 当线程读写申请成功后， 开始 对共享资源的读写操作，该操作持续相应时间后结束，并释放共享资源。六 结果分析和讨论在读者写

10、者同时在队列中等待申请资时， 读者优先调用资源。 而且如果一个 读者申请进行读操作时已有另一读者正在进行读操作， 则该读者可直接开始读操 作，即读读允许。进程1是R操作，在时间3时进入队列，运行时间是5,在它进入时没有进程 占用资源，它既占用资源；知道它释放资源，等候的进程有3， 4， 5；进程2是W操作，在时间16时进入队列，运行时间是5,在它进入时进程4 占用资源，它等待资源，当 4 释放时占用资源；进程3是R操作，在时间5时进入队列，运行时间是2,在它进入时进程1占 用资源，它等待资源，当进程 1 释放资源后，由于读者优先，进程 3， 5 同时调运资源；进程4是R操作，在时间6时进入队列

11、，运行时间是5,在它进入时进程1占 用资源，它等待资源，当进程 1 释放资源后，由于读者优先，进程 3， 5 占用资 源，它依然等待，直到进程 3， 5 都结束；进程 5 是 W 操作，在时间 4 时进入队列 ,运行时间是 3, 在它进入时进程 1 占用资源，它等待资源，当进程 1 释放资源后，由于读者优先，进程 3， 5同时 调运资源；七 心得体会这一次课程设计，让我体会很深刻。读者 -写者问题经典的线程同步问题的 一个模型。 经过读者写者问题的编写， 我对同步机构应用有了深入的了解。 懂得 了运用信号量实现进程间的互斥。 实现了不让共享资源同时修改。 用信号量上的 原语操作使临界段问题的解

12、决比较简单明了了。 读者写者问题的编写， 花的时间 很多，也学到很多东西。 了解支持多道程序的并发操作系统设计中解决资源共享 时进程间的同步与互斥的信号量机制。 几天的试验， 虽然难度有点大， 但只要自 己花时间去学习，还是会攻克困难的。总之，每一次课程设计不仅是我们学习的好机会， 而且是我们锻炼实际动手 能力的平台， 虽然有难度的东西总会让人很抵触， 比如在课设过程中有很多郁闷 的时候，一个小小的错误一不小心就花去了自己一上午的时间， 所以在这个过程 中能够磨练人的意志与耐心，最后感谢老师的指导与监督。八 源代码 #include <windows.h> #include <

13、;ctype.h> #include <stdio.h> #include <string.h> #include <stdlib.h>#include <malloc.h> #define MAX_PERSON 100#define READER 0 /读者#define WRITER 1 /写者#define END -1#define R READER#define W WRITERtypedef struct _PersonHANDLE m_hThread;/ 定义处理线程的句柄int m_nType;进程类型(读写)int m_n

14、StartTime; 开始时间int m_nWorkTime; 运行时间int m_nlD; 进程号Person;Person g_PersonsMAX_PERSON;int g_NumPerson = 0;long g_CurrentTime= 0;/基本时间片数int g_PersonLists = /进程队列1, R, 3, 5, 2, W, 4, 5, 3, R, 5, 2,4, R, 6, 5, 5, W, 5.1, 3, END,;int g_NumOfReading = 0;int g_NumOfWriteRequest = 0;/申请写进程的个数HANDLE g_hReadSe

15、maphore;/读者信号HANDLE g_hWriteSem aphore;/ 写者信号 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); D

16、WORD WINAPI WriterProc(LPVOID lpParam); int main()g_hReadSemaphore = CreateSemaphore(NULL,1,100,NULL); / 创建信号灯，当前 可用的资源数为 1，最大为 100g_hWriteSemaphore = CreateSemaphore(NULL,1,100,NULL); / 创建信号灯，当前 可用的资源数为 1，最大为 100CreatePersonList(g_PersonLists); / Create All the reader and writers printf("Creat

17、ed all the reader and writern.n");g_CurrentTime = 0; while(true) g_CurrentTime+;Sleep(300); / 300 ms printf("CurrentTime = %dn",g_CurrentTime);if(finished) return 0; / return 0;void CreatePersonList(int *pPersonLists)int i=0;int *pList = pPersonLists;bool Ret; while(pList0 != END) swi

18、tch(pList1) case R:Ret = CreateReader(pList2,pList3,pList0);/351,w452,523,654 break; case W:Ret = CreateWriter(pList2,pList3,pList0); break;if(!Ret)printf("Create Person %d is wrongn",pList0);pList += 4; / move to next person listDWORD WINAPI ReaderProc(LPVOID lpParam)/ 读过程Person *pPerson

19、= (Person*)lpParam;/ wait for the start time while(g_CurrentTime != pPerson->m_nStartTime) printf("Reader %d is Requesting .n",pPerson->m_nID);printf("nn*n");/ wait for the write requestWaitForSingleObject(g_hReadSemaphore,INFINITE); if(g_NumOfReading =0) WaitForSingleObjec

20、t(g_hWriteSemaphore,INFINITE); g_NumOfReading+;ReleaseSemaphore(g_hReadSemaphore,1,NULL); pPerson->m_nStartTime = g_CurrentTime;14printf("Reader %d is Reading the Shared Buffer.n",pPerson->m_nID);printf("nn*n");while(g_CurrentTime <= pPerson->m_nStartTime + pPerson-&g

21、t;m_nWorkTime) printf("Reader %d is Exit.n",pPerson->m_nID);printf("nn*n");WaitForSingleObject(g_hReadSemaphore,INFINITE); g_NumOfReading-;if(g_NumOfReading = 0)ReleaseSem aphore(g_hWriteSem aphore,1,NULL);此时没有读者，可以写 ReleaseSemaphore(g_hReadSemaphore,1,NULL);if(pPerson->m_n

22、ID = 4) finished = true; /所有的读写完成ExitThread(0); return 0;DWORD WINAPI WriterProc(LPVOID lpParam) Person *pPerson = (Person*)lpParam;/ wait for the start time while(g_CurrentTime != pPerson->m_nStartTime) printf("Writer %d is Requesting .n",pPerson->m_nID);printf("nn*n");Wai

23、tForSingleObject(g_hWriteSemaphore,INFINITE);/ modify the writer's real start time pPerson->m_nStartTime = g_CurrentTime;printf("Writer %d is Writting the Shared Buffer.n",pPerson->m_nID);while(g_CurrentTime <= pPerson->m_nStartTime + pPerson->m_nWorkTime) printf("W

24、riter %d is Exit.n",pPerson->m_nID);printf("nn*n");/g_NumOfWriteRequest-;ReleaseSemaphore(g_hWriteSemaphore,1,NULL);if(pPers on->m_nlD = 4) fini shed = true; 所有的读写完成ExitThread(0);return 0;bool CreateReader(int StartTime,int WorkTime,int lD)DWORD dwThreadlD;if(g_NumPerson >= MAX_PERSON) return false;Person *pPerson = &am