#include "StdAfx.h"
|
#include "PriorityThread.h"
|
|
#ifdef _DEBUG
|
#define new DEBUG_NEW
|
#undef THIS_FILE
|
static char THIS_FILE[] = __FILE__;
|
#endif
|
|
CPriorityThread::CPriorityThread(IPriorityThread2Parent* pFT2P, int nPriority) : CWorkThreadPool(1), m_pPT2P(pFT2P)
|
{
|
m_nPriority = nPriority;
|
}
|
|
CPriorityThread::~CPriorityThread(void)
|
{
|
|
}
|
|
void CPriorityThread::WorkThreadProcess(PVOID pParameter)
|
{
|
if (m_pPT2P==NULL) return;
|
|
CPriorityThreadData *pData = static_cast<CPriorityThreadData*>(pParameter);
|
if (pData==NULL) return;
|
|
HANDLE hThread = GetCurrentThread();
|
SetThreadPriority(hThread, m_nPriority);
|
|
m_pPT2P->IPT2P_PriorityThread(pData);
|
}
|
|
BOOL CPriorityThread::AddPriorityThreadData(UINT msg, WPARAM wParam, LPARAM lParam)
|
{
|
CPriorityThreadData *pData = new CPriorityThreadData(this);
|
if (pData==NULL) return FALSE;
|
|
pData->m_unMsg = msg;
|
pData->m_WParam = wParam;
|
pData->m_LParam = lParam;
|
|
return CreateWorkThread(pData);
|
}
|
