【100题】第三十四实现一个队列

一，题目：

生产者消费者线程演示
一个生产者线程将int类型的数入列，一个消费者线程将int类型的数出列

二，分析：

【100题】第三十四实现一个队列

这一个，为操作系统上的一个经典例子，以下是july给出的解答

三，源码：

#include <windows.h>   
#include <stdio.h>   
#include <process.h>   
#include <iostream>   
#include <queue>   
using namespace std;   
HANDLE ghSemaphore;   //信号量   
const int gMax = 100; //生产(消费)总数   
std::queue<int> q;      //生产入队,消费出队  
//生产者线程   
unsigned int __stdcall producerThread(void* pParam)    
{   
    int n = 0;   
    while(++n <= gMax)   
    {   
        //生产   
        q.push(n);   
        cout<<"produce"<<n<<endl;   
        ReleaseSemaphore(ghSemaphore, 1,NULL); //增加信号量   
        Sleep(300);//生产间隔的时间,可以和消费间隔时间一起调节   
    }   
    _endthread(); //生产结束   
    return 0;   
} 
  
//消费者线程
unsigned int __stdcall customerThread(void* pParam)
{
 int n = gMax;
 while(n--)
 {
  WaitForSingleObject(ghSemaphore, 10000);
  //消费
  
  q.pop();  
  cout<<"custom  "<<q.front()<<endl;   //小肥杨指出，原答案这句和上句搞错了顺序?
  Sleep(500);//消费间隔的时间,可以和生产间隔时间一起调节
 }
 //消费结束
 CloseHandle(ghSemaphore);
 cout<<"working end."<<endl;
 _endthread();
 return 0;
}
 
void threadWorking()   
{   
    ghSemaphore = CreateSemaphore(NULL, 0, gMax, NULL); //信号量来维护线程同步   
       
    cout<<"workingstart."<<endl;   
    unsigned threadID;   
    HANDLE handles[2];   
    handles[0] = (HANDLE)_beginthreadex(    
                   NULL,    
                   0,    
                   producerThread,    
                   NULL,    
                   0,    
                   &threadID);   
    handles[1] = (HANDLE)_beginthreadex(    
                   NULL,    
                   0,    
                   customerThread,    
                   NULL,    
                   0,    
                   &threadID);    
    WaitForMultipleObjects(2, handles, TRUE, INFINITE);   
}  
 
int main()   
{   
    threadWorking();   
    getchar();   
    return 0;   
}