Files
xdbg/Thread.cpp
2016-04-12 12:03:52 +08:00

81 lines
1.4 KiB
C++

#include <Windows.h>
#include "Thread.h"
#include "Utils.h"
Thread::Thread(void)
{
_threadHandle = NULL;
_threadId = 0;
}
Thread::~Thread(void)
{
if (_threadHandle != NULL) {
stop();
// CloseHandle(_threadHandle);
_threadHandle = NULL;
_threadId = 0;
}
}
bool Thread::start(size_t stackSize /* = 0 */)
{
if (!this->init())
return false;
_threadHandle = ::CreateThread(NULL, stackSize, threadProc, this, 0, &_threadId);
if (_threadHandle == NULL)
return false;
return true;
}
void Thread::stop(int exitCode)
{
::TerminateThread(_threadHandle, (DWORD )exitCode);
CloseHandle(_threadHandle);
_threadHandle = NULL;
_threadId = 0;
}
static DWORD exceptionFilter(EXCEPTION_POINTERS* excepInfo)
{
MyTrace("%s:%d - exception code: %d, exception address: %p",
__FILE__, __LINE__, excepInfo->ExceptionRecord->ExceptionCode,
excepInfo->ExceptionRecord->ExceptionAddress);
// assert(false);
return EXCEPTION_EXECUTE_HANDLER;
}
DWORD __stdcall Thread::threadProc(void* param)
{
// #define PAGE_SIZE 4096
// BYTE guardPages[PAGE_SIZE * 2 + 1];
// DWORD oldProt;
// VirtualProtect(&guardPages[PAGE_SIZE + 1], 1, PAGE_READONLY, &oldProt);
Thread* thisPtr = (Thread* )param;
DWORD result;
// __try {
result = (DWORD )thisPtr->run();
// } __except(exceptionFilter(GetExceptionInformation())) {
// }
thisPtr->final(result);
return result;
}
void Thread::wait()
{
WaitForSingleObject(_threadHandle, INFINITE);
}