北京电子科技学院（BESTI）实验报告课程：操作系统班级：0921 姓名：学号：成绩：指导教师：徐小青实验日期：2011.11.22 实验密级：/ 预习程度：代码实验时间：12:50-15:20 仪器组次：A04 必修/选修：必修实验序号：(一)实验名称：用信号量来实现读者-写者问题实验目的与要求：理解进程(或线程)及信号量的概念实验仪器：一、实验目的：理解进程(或线程)及信号量的概念二、实验内容：1、定义一个数据缓存buffer及用于实现同步互斥的信号量。
2、定义一个读者函数：●当有写者在占用buffer时，读者应该等待，直到写者不再使用该buffer。
●当有其他读者在占用buffer时，读者可对buffer进行读取操作。
●当buffer中有数据时，则从其中读取一个数据，并显示然后退出。
●当buffer中没有数据时，应等待，直到buffer中有数据可读。
3、定义一个写者函数●当有读者在占用buffer时，写者应该等待，直到所有的读者都退出为止。
●当有其他写者占用buffer时，该写者应该等待，直到占用buffer的写者退出为止。
●当buffer有空闲时，写者应该在buffer中写入一个数据并退出。
●当buffer满时，写者应该等待，直到buffer有空闲为止。
4、定义主函数，在其中可以任意创建读者与写者。
可根据用户输入创建读者或写者进程(线程)。
三、实验当堂完成内容：1，将设计好的思路以代码形式呈现，并调通。
2，将数据改变，看结果是否符合预期设想3，与同学交流，将代码完善。
四、设计思想：读进程：read(){P(Sr); 申请区域P(Scot); 锁定读者计数器first = first+1;if(first ==1)P(Sdoc);V(Scnt); 解锁读者计数器开始读；P(Scnt); 锁定读者计数器V(Sdoc);V(Scnt);V(Sr);}写进程：write(){P(sdoc);开始写;V(sdoc);}主函数设计思想：五、代码及具体解释：#include <stdlib.h>#include <windows.h>#include <stdio.h>#define P(S) WaitForSingleObject(S, INFINITE)// 这是Windows 下多线程工作的P 操作#define V(S) ReleaseSemaphore(S, 1, NULL)// 这是Windows 下多线程工作的V 操作const int RN = 5 ; // 所有读者总数（可以改变）const int WN = 3; // 所有写者总数（可以改变）HANDLE Sdoc; // 文档信号量——互斥量(临界区的信号量题目要求是1）HANDLE Sr; // 读者信号量——广义信号量（一次最多有多少个读者在读）HANDLE Scnt; // 保护g_cntReader 的互斥量（目前有多少读者正在读）int g_cntReader = 0; // 读者个数计数器// funcname : JustWait ( )// note: 显示一些信息，让后等待// ret val : void//// + Parameter :// [ int ] - nReader 读者（写者）编号，读者>0，写者<0// [ int ] - min 操作等待的最短时间// [ int ] - max 操作等待得最长时间，实际等待的时间介于两者之间// [ LPCSTR ] - info 要显示的信息void JustWait(int nReader, int min, int max, LPCSTR info);DWORD WINAPI Reader(LPVOID lpPara);DWORD WINAPI Writer(LPVOID lpPara);// 这是主函数void main(){Sdoc = CreateSemaphore(NULL, 1, 1, "Document");// 创建信号量初值，最大信号量值Sr = CreateSemaphore(NULL, 3, 3, "ReaderNumber"); // 一次最多允许3 个Scnt = CreateSemaphore(NULL, 1, 1, "ReaderCounterProtect");// 他也是一个互斥信号量，初值为 1HANDLE threads[RN+WN];for (int i=0; i<RN; i++) //不断创建读者线程threads[i] = CreateThread(0, 0, Reader, 0, 0, 0);for (int j=0; j<WN; j++)threads[j+RN] = CreateThread(0, 0, Writer, 0, 0, 0);WaitForMultipleObjects(RN+WN, threads, TRUE, INFINITE);}// 读者线程DWORD WINAPI Reader(LPVOID lpPara){// 注意是静态变量，可以使每来一个读者增加一static int reader_num = 1;int i = reader_num ++;int x=0;while (x<=5){JustWait(i, 1, 2, "我想读"); //1s的时候来，给2s的时间去读P(Sr); // 读者未满P(Scnt); // 锁定读者计数器printf("还有%d 个读者在读, 读者%d进入\n", g_cntReader, i);g_cntReader ++;if (g_cntReader == 1) // 如果是第一个读者{JustWait(i, 1, 2, "我是第一个!");P(Sdoc); // 锁定文档printf("读者%d说：有人在读，不可写文件\n", i);JustWait(i, 1, 2, "我可以读文件了！");V(Scnt); // 解锁读者计数器释放JustWait(i, 2, 5, "我在读");// 读ing…………JustWait(i, 1, 2, "我将要离开！");P(Scnt); // 锁定读者计数器g_cntReader --;if (g_cntReader == 0) // 如果是最后一个{JustWait(i, 1, 2, "我是最后一个!");printf("读者%d说：可以对文件操作了！~~~\n", i);V(Sdoc);// 解锁文档}printf("还有%d个读者在, 读者%d离开\n", g_cntReader, i);V(Scnt);// 解锁读者计数器V(Sr); // 离开JustWait(i, 5, 3, "结束");x++;printf("%d\n",x);}return 0;}DWORD WINAPI Writer(LPVOID lpPara){// 注意是静态变量，可以使每来一个写者减去一，注意初值是负值static int g_cnt = -1;int j = g_cnt --;while (1){JustWait(j, 2, 4, "我想写");// 锁定文档P(Sdoc);printf("\t写者%d说：文件正在修改不可操作\n", -j);JustWait(j, 4, 3, "写···"); // 写ing……JustWait(j, 1, 2, "写完了，离开");printf("写者%d说：可以对文件操作了\n", -j);V(Sdoc);// 解锁文档JustWait(j, 8, 4, "休息了");}return 0;}void JustWait(int nReader, int min, int max, LPCSTR info)//min为读者到来时间，max为读者离开时间{const int BASETIME = 1000;// 等待时间的基本量，以毫秒表示int wait_time = 0;// 实际等待得时间if (max==min) // 判断是为了避免%0错误，注意取随机值wait_time = min*BASETIME;//处理时间为0；elsechar s_out[128];// 最终显示的信息缓冲if (nReader > 0)// 读者大于0，写者小于0sprintf(s_out, "读者%d说: %s\n", nReader, info);elsesprintf(s_out, "\t写者%d说: %s\n", -nReader, info);printf(s_out);// 打印Sleep(wait_time);// 然后等待}//其设计思想是：读者在读，来了写着，创建写着线程，利用时间片区分他们。
