DWORD WINAPI mainThreadFunction(LPVOID lpParam){
	MainThread* mainThread = (MainThread*)lpParam;
	while(!mainThread->terminated)
	{
		mainThread->readQueue();
		Sleep(100);
	}

	return 0;
}

DWORD WINAPI slaveThreadFunction(LPVOID lpParam){
	SlaveThread* slaveThread = (SlaveThread*)lpParam;
	while(!slaveThread->terminated)
	{
		slaveThread->writeToQueue();
		Sleep(100);
	}

	return 0;
}

MainThread::MainThread()
{
	this->threadFunction = mainThreadFunction;
	this->functionArguments = this;
	this->mainQueue = new MessageQueue();
	this->CommonThread::startThread();
}

void MainThread::readQueue()
{
	size_t size;
	mainQueue->getSize(&size);
	while(size != 0)
	{
		CommonMessage* message = NULL;
		mainQueue->popMessage(&message);
		mainQueue->getSize(&size);
		delete message;
	}
}

SlaveThread::SlaveThread(MessageQueue* mainQueue)
{
	this->threadFunction = slaveThreadFunction;
	this->functionArguments = this;
	this->mainQueue = mainQueue;
	this->CommonThread::startThread();
}

void SlaveThread::writeToQueue()
{
	mainQueue->pushMessage(new CommonMessage(new LaunchReadingMessage(false)));
}

	MessageQueue* myQ = new MessageQueue();
	while(true)
	{
		CommonMessage* message = new CommonMessage(new LaunchReadingMessage(false));
		myQ->pushMessage(message);
		message = NULL;
		myQ->popMessage(&message);
		delete message;
		//Sleep(100);
	}

#include "stdafx.h"
#include "MessageQueue.h"

MessageQueue::MessageQueue()
{
	messageQueue = new queue<CommonMessage*>;
	InitializeCriticalSection(&criticalSection);
}

void MessageQueue::pushMessage(CommonMessage* message)
{
	EnterCriticalSection(&criticalSection);
	messageQueue->push(message);
	LeaveCriticalSection(&criticalSection);
}

CommonMessage* MessageQueue::popMessage(CommonMessage** message)
{
	EnterCriticalSection(&criticalSection);
	*message = messageQueue->front();
	messageQueue->pop();
	LeaveCriticalSection(&criticalSection);
	return *message;
}

size_t MessageQueue::getSize(size_t* size)
{
	EnterCriticalSection(&criticalSection);
	*size = messageQueue->size();
	LeaveCriticalSection(&criticalSection);
	return *size;
}

MessageQueue::~MessageQueue()
{
	while (messageQueue->size() != 0)
	{
		CommonMessage* tempMessage = NULL;
		tempMessage = popMessage(&tempMessage);
		delete tempMessage;
	}

	delete messageQueue;
	DeleteCriticalSection(&criticalSection);
}