操作系统课程设计--生产者和消费者.docVIP

#include windows.h #include iostream.h #includestdio.h const unsigned short SIZE_OF_BUFFER = 10; //缓冲区长度 unsigned short ProductID = 0; //产品号 unsigned short ConsumeID = 0; //将被消耗的产品号 unsigned short in = 0; //产品进缓冲区时的下标 unsigned short out = 0; //产品出缓冲区时的下标 int g_buffer[SIZE_OF_BUFFER]; //缓冲区是个循环队列 bool g_continue = true; //控制程序结束 HANDLE g_hMutex; //用于线程间的互斥 HANDLE g_hFullItems; //缓冲区中被占用的项 HANDLE g_hEmptyItems; //缓冲区中的空项 DWORD WINAPI Producer(LPVOID); //生产者线程,dword 变量类型的内存占位 DWORD WINAPI Consumer(LPVOID); //消费者线程 int main() { //创建各个互斥信号 g_hMutex = CreateMutex(NULL,FALSE,NULL); g_hFullItems = CreateSemaphore(NULL,0,SIZE_OF_BUFFER,NULL);//创建信号灯,createsemaphore常常被用作多线程同步 g_hEmptyItems = CreateSemaphore(NULL,SIZE_OF_BUFFER, SIZE_OF_BUFFER,NULL); //缓冲区初始化 for (int i = 0; i SIZE_OF_BUFFER;++i){ g_buffer[i] = -1; //当值为-1时该项为空 } const unsigned short PRODUCERS_COUNT =1; //生产者的个数 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 ( i=0;iPRODUCERS_COUNT;++i){ hThreads[i] =CreateThread(NULL,0,Producer,NULL,0,producerID[i]);//CreateThread是window提供的API函数 if (hThreads[i]==NULL) return -1; //用此函数可创建一个线程 } //创建消费者线程 for (i=0;iCONSUMERS_COUNT;++i){ hThreads[PROD