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
78
79
80
81
82
83
84
85
|
// Geometric Tools, LLC
// Copyright (c) 1998-2014
// Distributed under the Boost Software License, Version 1.0.
// http://www.boost.org/LICENSE_1_0.txt
// http://www.geometrictools.com/License/Boost/LICENSE_1_0.txt
//
// File Version: 5.0.0 (2010/01/01)
#include "Wm5CorePCH.h"
#include "Wm5Thread.h"
#include "Wm5Assert.h"
using namespace Wm5;
#if defined(WIN32)
//----------------------------------------------------------------------------
#include <windows.h>
//----------------------------------------------------------------------------
Thread::Thread (void* function, void* userData, unsigned int processorNumber,
unsigned int stackSize)
:
mFunction(function),
mUserData(userData),
mProcessorNumber(processorNumber),
mStackSize(stackSize)
{
mThread = CreateThread(NULL, (SIZE_T)stackSize,
(LPTHREAD_START_ROUTINE)function, (LPVOID)userData, CREATE_SUSPENDED,
(LPDWORD)&mThreadID);
}
//----------------------------------------------------------------------------
Thread::~Thread ()
{
// TODO: Write the threading system to allow graceful termination of
// each thread. The destructor is not the place to terminate. In C++,
// the thread function should exit (in C, ExitThread is the function to
// call). When it is time to exit, you can give the thread information
// to do so (via the userData).
}
//----------------------------------------------------------------------------
void Thread::Resume ()
{
DWORD result = ResumeThread((HANDLE)mThread);
assertion(result != (DWORD)-1, "Failed to resume thread\n");
WM5_UNUSED(result);
}
//----------------------------------------------------------------------------
void Thread::Suspend ()
{
DWORD result = SuspendThread((HANDLE)mThread);
assertion(result != (DWORD)-1, "Failed to suspend thread\n");
WM5_UNUSED(result);
}
//----------------------------------------------------------------------------
#elif defined(__LINUX__) || defined(__APPLE__)
//----------------------------------------------------------------------------
Thread::Thread (void* function, void* userData, unsigned int processorNumber,
unsigned int stackSize)
:
mFunction(function),
mUserData(userData),
mProcessorNumber(processorNumber),
mStackSize(stackSize)
{
// TODO.
}
//----------------------------------------------------------------------------
Thread::~Thread ()
{
// TODO.
}
//----------------------------------------------------------------------------
void Thread::Resume ()
{
// TODO.
}
//----------------------------------------------------------------------------
void Thread::Suspend ()
{
// TODO.
}
//----------------------------------------------------------------------------
#else
#error Other platforms not yet implemented.
#endif
//----------------------------------------------------------------------------
|
