#include "StdAfx.h"
|
#include "STimerThread.h"
|
|
CSTimerThread::CSTimerThread( DWORD dwPeriod/*=100*/, int nThreadCount/*=1*/ ) : m_dwPeriod(dwPeriod), CSThreadControl(nThreadCount)
|
{
|
m_pTimer = NULL;
|
m_pTimerCallback = TimerCallback;
|
}
|
|
|
CSTimerThread::~CSTimerThread(void)
|
{
|
StopThread();
|
}
|
|
DWORD CSTimerThread::GetPeriod() const
|
{
|
return m_dwPeriod;
|
}
|
|
VOID CALLBACK CSTimerThread::TimerCallback(PTP_CALLBACK_INSTANCE pInstance, PVOID pParameter, PTP_TIMER pTimer)
|
{
|
// Instance, Parameter, and Work not used in this example.
|
UNREFERENCED_PARAMETER(pInstance);
|
UNREFERENCED_PARAMETER(pParameter);
|
UNREFERENCED_PARAMETER(pTimer);
|
|
// Do something when the work callback is invoked.
|
CSTimerThread *pThreadPtr = static_cast<CSTimerThread*>(pParameter);
|
if (pThreadPtr)
|
{
|
pThreadPtr->TimerThreadProcess(pParameter);
|
}
|
|
return;
|
}
|
|
BOOL CSTimerThread::CreateTimerThread(PVOID pParameter)
|
{
|
if (m_pTimer) return FALSE;
|
|
if (NULL==m_pPool || NULL==m_pCleanupGroup) return FALSE;
|
|
m_pTimer = CreateThreadpoolTimer((PTP_TIMER_CALLBACK)TimerCallback, pParameter, &m_CallBackEnviron);
|
if (NULL==m_pTimer) return FALSE;
|
|
ULARGE_INTEGER ulDueTime;
|
FILETIME FileDueTime;
|
|
ulDueTime.QuadPart = (ULONGLONG)-(1 * 10 * 1000 * 1000);
|
FileDueTime.dwHighDateTime = ulDueTime.HighPart;
|
FileDueTime.dwLowDateTime = ulDueTime.LowPart;
|
|
SetThreadpoolTimer(m_pTimer, &FileDueTime, m_dwPeriod, 0);
|
|
return TRUE;
|
}
|
|
void CSTimerThread::CloseTimerThread()
|
{
|
if (NULL==m_pTimer) return;
|
|
WaitForThreadpoolTimerCallbacks(m_pTimer, TRUE);
|
|
CloseThreadpoolTimer(m_pTimer);
|
|
m_pTimer = NULL;
|
}
|
|
BOOL CSTimerThread::StartThread()
|
{
|
return CreateTimerThread(this);
|
}
|
|
void CSTimerThread::StopThread()
|
{
|
CloseTimerThread();
|
}
|
