|
#2
lonely_212012-07-16 20:09
#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; } 看看这个程序哪有问题 |
#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;
}