for (int i=0;i //从缓冲区中取出一个产品 void Take() { std::cerr << \ ConsumeID = buffer[out]; buffer[out] = 0; out = (out+1)%SIZE_OF_BUFFER; std::cerr << \ //输出缓冲区当前的状态 for (int i=0;i //消耗一个产品 void Consume() { std::cout << \ 21 std::cout << \} //生产者 DWORD WINAPI Producer(LPVOID lpPara) { while(p_ccontinue){ WaitForSingleObject(EmptySemaphore,INFINITE); WaitForSingleObject(Mutex,INFINITE); Produce(); Append(); Sleep(1500); ReleaseMutex(Mutex); //V(mutex); //p(empty); //p(mutex); ReleaseSemaphore(FullSemaphore,1,NULL); //V(full); } 4）CreateMutex能用CreateSemaphore替代吗？尝试修改程序3-1，将信号量Mutex完全用CreateSemaphore及相关函数实现。写出要修改的语句： Mutex = CreateSemaphore(NULL,0,SIZE_OF_BUFFER-1,NULL); （2）. 读者写者问题 根据实验（1）中所熟悉的P、V原语对应的实际Windows API函数，并参考教材中读者、写者问题的算法原理，尝试利用Windows API函数实现第一类读者写者问题（读者优先）。 3、 实验结论 _将信号量看作生产或消费的一个对象，对信号量的生成和销毁操作如同P操作和V操作一样，生成者消费者问题模拟的就是对信号量的生成和销毁，其中牵涉了信号量的同步，这也是该问题为何称为同步的经典问题的原因。 程序清单 清单3-1 生产者消费者问题 #include 22 #include const unsigned short SIZE_OF_BUFFER = 2; //缓冲区长度 unsigned short ProductID = 0; //产品号 unsigned short ConsumeID = 0; //将被消耗的产品号 unsigned short in = 0; //产品进缓冲区时的缓冲区下标 unsigned short out = 0; //产品出缓冲区时的缓冲区下标 int buffer[SIZE_OF_BUFFER]; //缓冲区是个循环队列 bool p_ccontinue = true; //控制程序结束 HANDLE Mutex; //用于线程间的互斥 HANDLE FullSemaphore; //当缓冲区满时迫使生产者等待 HANDLE EmptySemaphore; //当缓冲区空时迫使消费者等待 DWORD WINAPI Producer(LPVOID); //生产者线程 DWORD WINAPI Consumer(LPVOID); //消费者线程 int main() { //创建各个互斥信号 //注意，互斥信号量和同步信号量的定义方法不同，互斥信号量调用的是CreateMutex函数，同步信号量 //调用的是CreateSemaphore函数，函数的返回值都是句柄。 Mutex = CreateMutex(NULL,FALSE,NULL); EmptySemaphore = CreateSemaphore(NULL,SIZE_OF_BUFFER,SIZE_OF_BUFFER,NULL); //将上句做如下修改，看看结果会怎样 //EmptySemaphore = CreateSemaphore(NULL,0,SIZE_OF_BUFFER-1,NULL); FullSemaphore = CreateSemaphore(NULL,0,SIZE_OF_BUFFER,NULL); //调整下面的数值，可以发现，当生产者个数多于消费者个数时， //生产速度快，生产者经常等待消费者；反之，消费者经常等待 const unsigned short PRODUCERS_COUNT = 3; //生产者的个数 const unsigned short CONSUMERS_COUNT = 1; //消费者的个数 //总的线程数 const unsigned short THREADS_COUNT = PRODUCERS_COUNT+CONSUMERS_COUNT; HANDLE hThreads[THREADS_COUNT]; //各线程的handle DWORD producerID[PRODUCERS_COUNT]; //生产者线程的标识符 DWORD consumerID[CONSUMERS_COUNT]; //消费者线程的标识符 //创建生产者线程 for (int i=0;i hThreads[i]=CreateThread(NULL,0,Producer,NULL,0,&producerID[i]); 23 if (hThreads[i]==NULL) return -1; } //创建消费者线程 for (i=0;i hThreads[PRODUCERS_COUNT+i]=CreateThread(NULL,0,Consumer,NULL,0,&consumerID[i]); if (hThreads[i]==NULL) return -1; } while(p_ccontinue){ if(getchar()){ //按回车后终止程序运行 p_ccontinue = false; } } return 0; } //生产一个产品。简单模拟了一下，仅输出新产品的ID号 void Produce() { std::cout << std::endl<< \ std::cout << \} //把新生产的产品放入缓冲区 void Append() { std::cerr << \ buffer[in] = ProductID; in = (in+1)%SIZE_OF_BUFFER; std::cerr << \ //输出缓冲区当前的状态 for (int i=0;i //从缓冲区中取出一个产品 24 void Take() { std::cerr << \ ConsumeID = buffer[out]; buffer[out] = 0; out = (out+1)%SIZE_OF_BUFFER; std::cerr << \ //输出缓冲区当前的状态 for (int i=0;i //消耗一个产品 void Consume() { std::cout << \ std::cout << \} //生产者 DWORD WINAPI Producer(LPVOID lpPara) { while(p_ccontinue){ WaitForSingleObject(EmptySemaphore,INFINITE); //p(empty); WaitForSingleObject(Mutex,INFINITE); //p(mutex); Produce(); Append(); Sleep(1500); ReleaseMutex(Mutex); //V(mutex); ReleaseSemaphore(FullSemaphore,1,NULL); //V(full); } return 0; } //消费者 DWORD WINAPI Consumer(LPVOID lpPara) { while(p_ccontinue){ WaitForSingleObject(FullSemaphore,INFINITE); //P(full); 25 百度搜索“77cn”或“免费范文网”即可找到本站免费阅读全部范文。收藏本站方便下次阅读，免费范文网，提供经典小说教育文库os实验指导书（新）(5)在线全文阅读。
相关推荐：