From bad78945ceba425f6a80e3b8dca2414d592970eb Mon Sep 17 00:00:00 2001
From: chai <chaifix@163.com>
Date: Fri, 2 Aug 2019 20:51:00 +0800
Subject: =?UTF-8?q?*=E4=BF=AE=E6=94=B9=E6=96=87=E4=BB=B6=E5=90=8D=E6=A0=BC?=
 =?UTF-8?q?=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../asura-utils/Threads/ThreadImplWin32.cpp        | 77 ++++++++++++++++++++++
 1 file changed, 77 insertions(+)
 create mode 100644 source/modules/asura-utils/Threads/ThreadImplWin32.cpp

(limited to 'source/modules/asura-utils/Threads/ThreadImplWin32.cpp')

diff --git a/source/modules/asura-utils/Threads/ThreadImplWin32.cpp b/source/modules/asura-utils/Threads/ThreadImplWin32.cpp
new file mode 100644
index 0000000..2467f87
--- /dev/null
+++ b/source/modules/asura-utils/Threads/ThreadImplWin32.cpp
@@ -0,0 +1,77 @@
+#include "ThreadImplWin32.h"
+#include "Thread.h"
+
+#include <iostream>
+
+#if ASURA_THREAD_WIN32
+
+namespace_begin(AsuraEngine)
+namespace_begin(Threads)
+
+static DWORD WINAPI _thread_win32_runner(LPVOID param)
+{
+	Threadable* thread = (Threadable*)param;
+	return thread->Process(); // 尾调用
+}
+
+ThreadImplWin32::ThreadImplWin32()
+{
+}
+
+ThreadImplWin32::~ThreadImplWin32()
+{
+	if (!m_Handle) return;
+	::CloseHandle(m_Handle);
+	m_Handle = 0;
+}
+
+bool ThreadImplWin32::Start(Threadable* thread, uint32 stacksize/*=0*/)
+{
+	assert(!IsRunning());
+	m_Handle = ::CreateThread(
+		NULL
+		, stacksize
+		, _thread_win32_runner
+		, thread
+		, 0 /*创建后立即进行调度*/
+		, NULL);
+
+	return m_Handle;
+}
+
+void ThreadImplWin32::Join()
+{
+	// 父线程等待此线程返回
+	::WaitForSingleObject(m_Handle, INFINITE);
+}
+
+void ThreadImplWin32::Kill()
+{
+	::TerminateThread(m_Handle, FALSE);
+}
+
+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