任务4-同步对象解决有限缓冲区问题.doc

基本信息 实践题目：同步对象解决有限缓冲区问题 完成人： 班级姓名：陈杨 学号：0706230101 报告日期 ：2011年1月6日 实践内容简要描述 实践目标 1.掌握Win32提供的同步对象的使用方法 2. 理解有限缓冲区问题并用同步对象解决该问题 实践内容 用Win32提供的同步对象解决有限缓冲区问题 写一个多线程实现C/C++程序：一些线程负责找出某个数据范围的素数，并放到一个数组中，另一些线程负责将数组中的素数按次序取出，并显示出来。 要求定义一个全局变量的数组：int prime[9] 用于存放找到的待显示的素数，要理解成“环形缓冲区”。 测试数据示例： 1 W 10 100 2 W 1 10 3 D 3 0 说明：每行四个元素：第一个是线程ID；第二个是线程角色（D——显示结果线程，W——找素数线程）；若是显示结果线程，则第三个数字表示该线程需要显示的素数个数，第四个数始终为零；若是找素数线程，则第三，第四个数表示找素数的范围。 要求使用“生产者-消费者”算法，找素数线程每次只能放入一个素数，显示线程每次只能取一个素数。 设计思路 程序分成两个层，数据层和表示层： 数据层负责对缓冲区的处理，包括放数据和取数据，并实现同步互斥机制 表示层调用数据层提供的功能，并负责显示结果 线程方面，首先创建主线程，主线程负责初始化数据层，并创建读写子线程。子线程各司其职，调用数据层的功能，或放数据，或取数据。 主要数据结构 #define BUFFER_LENGTH 9 int prime[BUFFER_LENGTH]; int begIndex; int endIndex; HANDLE emptySemaphore; HANDLE fullSemaphore; CRITICAL_SECTION writerCS; CRITICAL_SECTION readerCS; int readerCount; int writerCount; CRITICAL_SECTION readerCountCS; CRITICAL_SECTION writerCountCS; CRITICAL_SECTION consoleOwnerCS; // threads related struct MyThread { int id; HANDLE hThead; DWORD dwThread; MyThread* next; }; MyThread* head; // thread functions struct FindParam { int start; int end; }; struct DisplayParam { int count; int threadId; }; 主要代码结构及分析 int main() { ifstream fin(ex4.dat); if(!fin) { cout Cannot find file \ex4.dat\.\nPress any key to exit.; _getch(); return 1; } initBuf(); head = NULL; MyThread* p = head; while(!fin.eof()) { MyThread* pp = new MyThread; fin pp-id; char type; fin type; if(type == D) { DisplayParam* dp = new DisplayParam; fin dp-count; dp-threadId = pp-id; while(!fin.eof() fin.get() != \n); pp-hThead = CreateThread(NULL, 0, display, dp, 0, pp-dwThread); } else if(type == W) { FindParam* fp = new FindParam; fin fp-start; fin fp-end; while(!fin.eof() fin.get() != \n); pp-hThead = CreateThread(NULL, 0, findPrime, fp, 0, pp-dwThread); } else { cout Error thread type.\n; while(!fin.eof() fin.get() != \n); continue; } pp-next = NULL; if(