#include <windows.h>
#include <iostream>
using namespace std;
#include <malloc.h>
#define BUFFERSIZE 8

template<class T>
class Queue
{
    T *data;
    int front,rear;
    int curlen;
public:
    Queue():front(0),rear(0),curlen(0)
    {
        data = (T*)malloc(sizeof(T)*BUFFERSIZE);
    }
    void EnQue(T x)
    {
        if(isfull()) return;
        data[rear++] = x;
        rear = rear%8;
        curlen++;
    }
    void DeQueue(T &x)
    {
        if(isempty()) return;
        x=data[front];
        front = (front+1)%8;
        curlen--;
    }
    T GetTop()
    {

    }
    bool isempty()
    {
        return (curlen == 0);
    }
    bool isfull()
    {
        return (curlen == 8);
    }
    ~Queue()
    {
        if(data != NULL)
        {
            free(data);
            data = NULL;
            curlen = front = rear = 0;
        }

    }
};
Queue<int> qu;
HANDLE pro;
HANDLE con;
HANDLE s;


DWORD _stdcall producer(LPVOID)
{
    for(int i=0; i < 20; i++)
    {
        WaitForSingleObject(s,-1);
        if(qu.isfull())
        {
            WaitForSingleObject(pro,-1);         //等待pro变为大于0
        }
        qu.EnQue(i);
        printf("生产 %d\n",i);
        ReleaseSemaphore(con,1,NULL);
        ReleaseSemaphore(s,1,NULL);

    }
    WaitForSingleObject(s,-1);
    qu.EnQue(-1);
    printf("生产结束\n");
    ReleaseSemaphore(con,1,NULL);
    ReleaseSemaphore(s,1,NULL);
    return 0;
}
DWORD _stdcall consumer(LPVOID)
{
    int x;
    for(;;)
    {
        WaitForSingleObject(s,-1);
        if(qu.isempty())
        {
            WaitForSingleObject(con,-1);                     //等待con变为大于0
        }
        qu.DeQueue(x);
        if(x == -1)
            break;
        printf("消费 %d\n",x);
        ReleaseSemaphore(pro,1,NULL);
        ReleaseSemaphore(s,1,NULL);
        
    }
    printf("消费结束\n");
    ReleaseSemaphore(s,1,NULL);
    return 0;
}
int main()
{
    pro = CreateSemaphore(NULL,1,1,NULL);
    con = CreateSemaphore(NULL,0,1,NULL);
    s   = CreateSemaphore(NULL,2,2,NULL);
    HANDLE hThrds[2];
    DWORD id;
    hThrds[0] = CreateThread(NULL,0,producer,NULL,-1,&id);
    hThrds[1] = CreateThread(NULL,0,consumer,NULL,-1,&id);
    WaitForMultipleObjects(2,hThrds,true,-1);
    CloseHandle(hThrds[0]);
    CloseHandle(hThrds[1]);
    return 0;
}

#include <windows.h>
#include <iostream>
using namespace std;
#include <malloc.h>
#define BUFFERSIZE 8

template<class T>
class Queue
{
    T *data;
    int front,rear;
    int curlen;
public:
    Queue():front(0),rear(0),curlen(0)
    {
        data = (T*)malloc(sizeof(T)*BUFFERSIZE);
    }
    void EnQue(T x)
    {
        if(isfull()) return;
        data[rear++] = x;
        rear = rear%8;
        curlen++;
    }
    void DeQueue(T &x)
    {
        if(isempty()) return;
        x=data[front];
        front = (front+1)%8;
        curlen--;
    }
    T GetTop()
    {

    }
    bool isempty()
    {
        return (curlen == 0);
    }
    bool isfull()
    {
        return (curlen == 8);
    }
    ~Queue()
    {
        if(data != NULL)
        {
            free(data);
            data = NULL;
            curlen = front = rear = 0;
        }

    }
};
Queue<int> qu;
HANDLE hMutex;
HANDLE isEmpty;
HANDLE isFull;


DWORD _stdcall producer(LPVOID)
{
    for(int i=0; i < 20; i++)
    {
        WaitForSingleObject(isFull,-1);
        WaitForSingleObject(hMutex,-1);
        qu.EnQue(i);
        printf("producer : %d\n",i);
        Sleep(1500);
        ReleaseMutex(hMutex);
        ReleaseSemaphore(isEmpty,1,NULL);        

    }

    printf("生产结束\n");
    return 0;
}
DWORD _stdcall consumer(LPVOID)
{
    int x;
    for(;;)
    {
        WaitForSingleObject(isEmpty,-1);
        WaitForSingleObject(hMutex,-1);
        qu.DeQueue(x);
        printf("producer : %d\n",x);
        Sleep(1500);
        ReleaseMutex(hMutex);
        ReleaseSemaphore(isFull,1,NULL);
   
    }
    printf("消费结束\n");
    return 0;
}
int main()
{
    isEmpty = CreateSemaphore(NULL,0,BUFFERSIZE-1,NULL);
    isFull  = CreateSemaphore(NULL,BUFFERSIZE,BUFFERSIZE,NULL);
    hMutex  = CreateMutex(NULL,false,NULL);
    HANDLE hThrds[2];
    DWORD id;
    hThrds[0] = CreateThread(NULL,0,producer,NULL,-1,&id);
    hThrds[1] = CreateThread(NULL,0,consumer,NULL,-1,&id);
    WaitForMultipleObjects(2,hThrds,true,-1);
    CloseHandle(hThrds[0]);
    CloseHandle(hThrds[1]);
    return 0;
}
看看这个程序哪有问题

你妹啊，这么长

你妹啊