|
#include "StdAfx.h"
#include "MTQueueConsumer.h"
#include "MTQueueSingleton.h"
CMTQueueConsumer::CMTQueueConsumer(void)
{
}
CMTQueueConsumer::~CMTQueueConsumer(void)
{
}
bool CMTQueueConsumer::Execute(void)
{
void* pMsg = NULL;
while (!m_bStop)
{
pMsg = NULL;
if(TheQueueBuffer::GetInstance()->Pop(pMsg))
{
SendMessageToObs(WM_MSG_DATA,NULL,(LPARAM) pMsg);
}
else
{
Sleep(66);
}
}
return true;
}
|
By viewing downloads associated with this article you agree to the Terms of Service and the article's licence.
If a file you wish to view isn't highlighted, and is a text file (not binary), please
let us know and we'll add colourisation support for it.
Senior Software Developer in C/C++ and Oracle.
Ex-physicist holding a Ph.D. on x-ray lasers.