clobber
43 lines
1002 B
C++
43 lines
1002 B
C++
#include "Worker.h"
|
|
#include <windows.h>
|
|
#include <process.h>
|
|
|
|
unsigned int __stdcall ThreadEntry(void* classInstance);
|
|
|
|
Worker::Worker(void (*workerFunction)(void*), void* workerFunctionArgument)
|
|
{
|
|
this->startEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
|
|
this->threadHandle = (HANDLE)_beginthreadex( NULL, 0, ThreadEntry, this, 0, &this->threadId );
|
|
this->internalWorkerFunction = workerFunction;
|
|
this->internalWorkerFunctionArgument = workerFunctionArgument;
|
|
}
|
|
|
|
Worker::~Worker()
|
|
{
|
|
}
|
|
|
|
void Worker::Run()
|
|
{
|
|
SetEvent(this->startEvent);
|
|
}
|
|
|
|
void Worker::Wait()
|
|
{
|
|
WaitForSingleObject(this->threadHandle, INFINITE);
|
|
}
|
|
|
|
////////////////////////////
|
|
|
|
void Worker::_ThreadFunction()
|
|
{
|
|
// Wait until we're told to start.
|
|
WaitForSingleObject(this->startEvent, INFINITE);
|
|
|
|
this->internalWorkerFunction(this->internalWorkerFunctionArgument);
|
|
}
|
|
|
|
unsigned int __stdcall ThreadEntry(void* classInstance)
|
|
{
|
|
((Worker*)classInstance)->_ThreadFunction();
|
|
return 0;
|
|
} |