From 084623519e95f0ab0cf4bc328b5fa736d679c5bd Mon Sep 17 00:00:00 2001 From: chai Date: Wed, 31 Jul 2019 21:35:12 +0800 Subject: =?UTF-8?q?*=E4=BF=AE=E6=94=B9=E5=90=8D=E7=A7=B0=E7=A9=BA=E9=97=B4?= =?UTF-8?q?=E9=A3=8E=E6=A0=BC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../asura-utils/threading/thread_impl_win32.cpp | 116 ++++++++++----------- 1 file changed, 57 insertions(+), 59 deletions(-) (limited to 'source/modules/asura-utils/threading/thread_impl_win32.cpp') diff --git a/source/modules/asura-utils/threading/thread_impl_win32.cpp b/source/modules/asura-utils/threading/thread_impl_win32.cpp index 61b1c13..c876be9 100644 --- a/source/modules/asura-utils/threading/thread_impl_win32.cpp +++ b/source/modules/asura-utils/threading/thread_impl_win32.cpp @@ -5,75 +5,73 @@ #if ASURA_THREAD_WIN32 -namespace AsuraEngine -{ - namespace Threading - { - - static DWORD WINAPI _thread_win32_runner(LPVOID param) - { - Threadable* thread = (Threadable*)param; - return thread->Process(); // 尾调用 - } - - ThreadImplWin32::ThreadImplWin32() - { - } +namespace_begin(AsuraEngine) +namespace_begin(Threading) - ThreadImplWin32::~ThreadImplWin32() - { - if (!m_Handle) return; - ::CloseHandle(m_Handle); - m_Handle = 0; - } +static DWORD WINAPI _thread_win32_runner(LPVOID param) +{ + Threadable* thread = (Threadable*)param; + return thread->Process(); // 尾调用 +} - bool ThreadImplWin32::Start(Threadable* thread, uint32 stacksize/*=0*/) - { - assert(!IsRunning()); - m_Handle = ::CreateThread( - NULL - , stacksize - , _thread_win32_runner - , thread - , 0 /*创建后立即进行调度*/ - , NULL); +ThreadImplWin32::ThreadImplWin32() +{ +} - return m_Handle; - } +ThreadImplWin32::~ThreadImplWin32() +{ + if (!m_Handle) return; + ::CloseHandle(m_Handle); + m_Handle = 0; +} - void ThreadImplWin32::Join() - { - // 父线程等待此线程返回 - ::WaitForSingleObject(m_Handle, INFINITE); - } +bool ThreadImplWin32::Start(Threadable* thread, uint32 stacksize/*=0*/) +{ + assert(!IsRunning()); + m_Handle = ::CreateThread( + NULL + , stacksize + , _thread_win32_runner + , thread + , 0 /*创建后立即进行调度*/ + , NULL); - void ThreadImplWin32::Kill() - { - ::TerminateThread(m_Handle, FALSE); - } + return m_Handle; +} - void ThreadImplWin32::Sleep(uint ms) - { - ::Sleep(ms); - } +void ThreadImplWin32::Join() +{ + // 父线程等待此线程返回 + ::WaitForSingleObject(m_Handle, INFINITE); +} - bool ThreadImplWin32::IsRunning() - { - if (m_Handle) { - DWORD exitCode = 0; - // https://blog.csdn.net/yuanmeng567/article/details/19485719 - ::GetExitCodeThread(m_Handle, &exitCode); - return exitCode == STILL_ACTIVE; - } - return false; - } +void ThreadImplWin32::Kill() +{ + ::TerminateThread(m_Handle, FALSE); +} - bool ThreadImplWin32::IsCurrent() - { - return m_Handle == ::GetCurrentThread(); - } +void ThreadImplWin32::Sleep(uint ms) +{ + ::Sleep(ms); +} +bool ThreadImplWin32::IsRunning() +{ + if (m_Handle) { + DWORD exitCode = 0; + // https://blog.csdn.net/yuanmeng567/article/details/19485719 + ::GetExitCodeThread(m_Handle, &exitCode); + return exitCode == STILL_ACTIVE; } + return false; } +bool ThreadImplWin32::IsCurrent() +{ + return m_Handle == ::GetCurrentThread(); +} + +namespace_end +namespace_end + #endif // ASURA_THREAD_WIN32 \ No newline at end of file -- cgit v1.1-26-g67d0