95 lines
2.1 KiB
C++
95 lines
2.1 KiB
C++
#include "StdAfx.h"
|
|
#include "Thread.h"
|
|
|
|
|
|
//---------------------------------------------------------------------------
|
|
// Thread Class
|
|
//---------------------------------------------------------------------------
|
|
|
|
|
|
//---------------------------------------------------------------------------
|
|
// Constructor
|
|
//---------------------------------------------------------------------------
|
|
|
|
CThread::CThread() :
|
|
m_dwThreadId(0),
|
|
m_hStopEvent(CreateEvent(NULL, TRUE, FALSE, NULL))
|
|
{
|
|
}
|
|
|
|
|
|
//---------------------------------------------------------------------------
|
|
// Destructor
|
|
//---------------------------------------------------------------------------
|
|
|
|
CThread::~CThread()
|
|
{
|
|
}
|
|
|
|
|
|
//---------------------------------------------------------------------------
|
|
// Start Thread
|
|
//---------------------------------------------------------------------------
|
|
|
|
void CThread::StartThread()
|
|
{
|
|
// reset exit event
|
|
|
|
ResetEvent(m_hStopEvent);
|
|
|
|
// create thread
|
|
|
|
m_hThread = CreateThread(NULL, 0, ThreadProc, this, 0, &m_dwThreadId);
|
|
|
|
if (m_hThread == NULL)
|
|
{
|
|
// ThrowError(HRESULT_FROM_WIN32(GetLastError()), _T("Unable to create thread."));
|
|
}
|
|
}
|
|
|
|
|
|
//---------------------------------------------------------------------------
|
|
// Stop Thread
|
|
//---------------------------------------------------------------------------
|
|
|
|
void CThread::StopThread()
|
|
{
|
|
SetEvent(m_hStopEvent);
|
|
|
|
if (m_hThread != NULL)
|
|
{
|
|
WaitForSingleObject(m_hThread, INFINITE);
|
|
}
|
|
}
|
|
|
|
|
|
//---------------------------------------------------------------------------
|
|
// Thread Procedure
|
|
//---------------------------------------------------------------------------
|
|
|
|
DWORD WINAPI CThread::ThreadProc(LPVOID pvParameter)
|
|
{
|
|
// initialize COM library for this thread
|
|
// setting thread concurrency model to multi-threaded
|
|
|
|
HRESULT hr = CoInitializeEx(NULL, COINIT_MULTITHREADED);
|
|
|
|
if (SUCCEEDED(hr))
|
|
{
|
|
CThread* pThis = reinterpret_cast<CThread*>(pvParameter);
|
|
|
|
try
|
|
{
|
|
pThis->Run();
|
|
}
|
|
catch (...)
|
|
{
|
|
;
|
|
}
|
|
|
|
CoUninitialize();
|
|
}
|
|
|
|
return 0;
|
|
}
|