blob: 2467f87c0909e732cffad7e74e46f9709bf419d5 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
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
|
