test.cpp

这是书上的代码

#include <stdio.h>
#include <process.h>
#include "definition.h"


class CRWLock rwl;
unsigned long counter = 0;
CExclusionCircleQueue<unsigned long> queue;

void Writer1(void *param)
{
	while(1)
	{
		queue.PutTailer(++counter);
		Sleep(50); 
	}
}
void Writer2(void *param)
{
	while(1)
	{
		queue.PutTailer(++counter);
		Sleep(100); 
	}
}
void Reader(void *param)
{
	unsigned long temp;
	while(1)
	{
		queue.GetHeader(temp);
		Sleep(500); 
	}
}

void main()
{
	queue.Create(100);

	_beginthread(Writer1,0,0);
	_beginthread(Writer2,0,0);
	_beginthread(Reader,0,0);
	_beginthread(Reader,0,0);
	_beginthread(Reader,0,0);

	Sleep(3000000);

	queue.Close();
}