1 files changed, 51 insertions, 0 deletions
diff --git a/CPP/Windows/Thread.h b/CPP/Windows/Thread.h
new file mode 100755
index 00000000..5b676027
--- /dev/null
+++ b/CPP/Windows/Thread.h
@@ -0,0 +1,51 @@
+// Windows/Thread.h
+
+#ifndef __WINDOWS_THREAD_H
+#define __WINDOWS_THREAD_H
+
+// #include <process.h>
+
+#include "Handle.h"
+#include "Defs.h"
+
+namespace NWindows {
+
+class CThread: public CHandle
+{
+  bool IsOpen() const { return _handle != 0; }
+public:
+  bool Create(LPSECURITY_ATTRIBUTES threadAttributes, 
+      SIZE_T stackSize, LPTHREAD_START_ROUTINE startAddress,
+      LPVOID parameter, DWORD creationFlags, LPDWORD threadId)
+  {
+    _handle = ::CreateThread(threadAttributes, stackSize, startAddress,
+        parameter, creationFlags, threadId);
+    return (_handle != NULL);
+  }
+  bool Create(LPTHREAD_START_ROUTINE startAddress, LPVOID parameter)
+  {
+    DWORD threadId;
+    return Create(NULL, 0, startAddress, parameter, 0, &threadId);
+    /*
+    _handle = (HANDLE)_beginthreadex(NULL, 0, startAddress, parameter, 0, NULL);
+    return (_handle != NULL);
+    */
+  }
+
+  DWORD Resume() { return ::ResumeThread(_handle); }
+  DWORD Suspend() { return ::SuspendThread(_handle); }
+  bool Terminate(DWORD exitCode) { return BOOLToBool(::TerminateThread(_handle, exitCode)); }
+  int GetPriority() { return ::GetThreadPriority(_handle); }
+  bool SetPriority(int priority) { return BOOLToBool(::SetThreadPriority(_handle, priority)); }
+
+  bool Wait() 
+  { 
+    if (!IsOpen())
+      return true;
+    return (::WaitForSingleObject(_handle, INFINITE) == WAIT_OBJECT_0); 
+  }
+};
+
+}
+
+#endif