From 60cbbdec07ab7a5636eac5b3c024ae44e937f4d4 Mon Sep 17 00:00:00 2001
From: chai <chaifix@163.com>
Date: Mon, 13 Dec 2021 00:07:19 +0800
Subject: +init

---
 Client/Source/Threading/Thread.h | 71 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 71 insertions(+)
 create mode 100644 Client/Source/Threading/Thread.h

(limited to 'Client/Source/Threading/Thread.h')

diff --git a/Client/Source/Threading/Thread.h b/Client/Source/Threading/Thread.h
new file mode 100644
index 0000000..77d8dff
--- /dev/null
+++ b/Client/Source/Threading/Thread.h
@@ -0,0 +1,71 @@
+#pragma once
+#include <windows.h>
+#include <vector>
+#include <exception>
+
+#include "../Utilities/Type.h"
+
+#include "Job.h"
+#include "Mutex.h"
+
+class ThreadException : public std::exception
+{
+public:
+	ThreadException(const char* what)
+		: std::exception(what)
+	{
+	}
+};
+
+class Thread
+{
+public:
+	Thread(uint32 stacksize = 0)/*throw ThreadExeception*/;
+	virtual ~Thread();
+
+	virtual void Run() = 0;
+
+	virtual void Resume();
+	virtual void Join() ;
+	virtual void Kill() ;
+
+	virtual void Sleep(uint ms) ;
+
+	virtual bool IsRunning() ;
+	virtual bool IsCurrent() ;
+
+protected:
+	HANDLE m_Handle;
+
+};
+
+// 任务系统的线程
+class WorkThread : public Thread
+{
+public:
+	void Run() override;
+	void Dispatch(void* param); // call in main thread
+
+	void AddJobAtEnd(Job* job);
+
+private:
+	Mutex m_PendingMutex;
+	Mutex m_FinishedMutex;
+
+	std::vector<Job*> m_PendingJobs;
+	std::vector<Job*> m_FinishedJobs;
+
+};
+
+// 执行小段代码的线程
+class CodePieceThread : public Thread 
+{
+public: 
+	typedef void(*CodePiece)();
+
+	void Run() override;
+
+private: 
+	std::vector<CodePiece> m_CodePieces;
+
+};
\ No newline at end of file
-- 
cgit v1.1-26-g67d0