blob: 6871c2d49aef2d31d8d975be302912439099d77e (
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
|
#include "thread_impl_win32.h"
#include "thread.h"
#include <iostream>
namespace AsuraEngine
{
namespace Threading
{
static DWORD WINAPI _thread_win32_runner(LPVOID param)
{
Thread* thread = (Thread*)param;
thread->Process();
return 0;
}
ThreadImplWin32::ThreadImplWin32()
{
}
ThreadImplWin32::~ThreadImplWin32()
{
if (!mHandle) return;
::CloseHandle(mHandle);
mHandle = 0;
}
bool ThreadImplWin32::Start(Thread* thread, uint32 stacksize/*=0*/)
{
assert(!IsRunning());
mHandle = ::CreateThread(
NULL
, stacksize
, _thread_win32_runner
, thread
, 0 /*е*/
, NULL);
return mHandle;
}
void ThreadImplWin32::Join()
{
// ̵߳ȴ̷߳
::WaitForSingleObject(mHandle, INFINITE);
}
void ThreadImplWin32::Kill()
{
::TerminateThread(mHandle, FALSE);
}
void ThreadImplWin32::Sleep(uint ms)
{
::Sleep(ms);
}
bool ThreadImplWin32::IsRunning()
{
if (mHandle) {
DWORD exitCode = 0;
// https://blog.csdn.net/yuanmeng567/article/details/19485719
::GetExitCodeThread(mHandle, &exitCode);
return exitCode == STILL_ACTIVE;
}
return false;
}
bool ThreadImplWin32::IsCurrent()
{
return mHandle == ::GetCurrentThread();
}
}
}
|
