*misc

1 files changed, 221 insertions, 0 deletions

diff --git a/source/libs/asura-lib-utils/threading/thread.h b/source/libs/asura-lib-utils/threading/thread.h
new file mode 100644
index 0000000..0e75770
--- /dev/null
+++ b/source/libs/asura-lib-utils/threading/thread.h
@@ -0,0 +1,221 @@
+#ifndef __ASURA_THREAD_H__
+#define __ASURA_THREAD_H__
+
+#include <string>
+#include <queue>
+
+#include <asura-lib-utils/scripting/portable.hpp>
+
+#include "task.h"
+#include "mutex.h"
+#include "semaphore.h"
+
+namespace AsuraEngine
+{
+	namespace Threading
+	{
+
+		class ThreadImpl;
+
+		///
+		/// �̵߳ļ��ֲ�ͬ��ʵ�֣�
+		///     1: Deferred���ӳ�ģʽ�����߳��ϵ�������ɺ���Ҫ�ֶ������̵߳���Post������
+		///        �����̵߳��ص����������������첽��Ϊͬ�������������lua_State��ͻ�����⡣
+		///     2: Immediate������ģʽ����ÿһ���߳�ά��һ��lua_newthread����������lua_State��
+		///        �ص������ڲ�ͬ��lua_State�е��ã����ⲻͬ���̷߳���ͬһ��lua_State��
+		///
+		enum ThreadType
+		{
+			THREAD_TYPE_DEFERRED,
+			THREAD_TYPE_IMMEDIATE,
+		};
+
+		enum ThreadState
+		{
+			THREAD_STATE_IDLE,    ///< ���ã���δ�����ں˶���
+			THREAD_STATE_RUNNING,	///< ��������ѭ��
+			THREAD_STATE_PAUSED,	///< ��ѭ������ͣ
+			THREAD_STATE_STOPPED,	///< �˳�ѭ��
+		};
+
+		///
+		/// �߳����壬ÿ���߳�ά��һ��task queue��
+		///
+		class Thread ASURA_FINAL
+			: public AEScripting::Portable<Thread>
+		{
+		public:
+
+			LUAX_DECL_FACTORY(Thread);
+
+			Thread(lua_State* luaThread, ThreadType type = THREAD_TYPE_DEFERRED, uint sleepTime = 1, const std::string& name = "");
+			~Thread();
+
+			bool AddTask(Task* task);
+			///
+			/// ��õȴ�������������
+			///
+			uint GetTaskCount();
+
+			void Idle();
+
+			///
+			/// �����ں˶��󣬲����С������daemon����ȴ��ֶ�stop���������ijʱ�̶�����ɺ��Զ�stop��
+			///
+			bool Start(bool daemon = true, uint32 stacksize = 0);
+
+			///
+			/// ��ͬ���߳̿��ƣ�����ʵʱ�ġ�������Ҫ�����߳���ʹ��Is����ȷ�ϵ���ָ��״̬��
+			///
+			void Pause();
+			void Resume();
+			void Stop();
+
+			///
+			/// ͬ���߳̿��ƣ���ȷ������źź��������ִ�С���������̵߳ȴ���
+			///
+			void PauseSync();
+			void ResumeSync();
+			void StopSync();
+
+			///
+			/// ���̵߳ȴ����߳̽�����ż���ִ�С�
+			///
+			void Join();
+
+			ThreadState GetState();
+
+			///
+			/// �߼�������߳�״̬��
+			///     1: Idle�����У����̴߳������Ĭ��״̬��������ʱ��������Start��
+			///     2: Running�����У����ں˶����´������Ѿ������ں˵����У�����������Task��
+			///     3: Paused����ͣ������Ȼ�������ں��У����������˶�����Ĵ������߼�����ͣ��
+			///     4: Stopped��ֹͣ������Ȼ�������ں��У������Ѿ��޷�������������
+			/// 
+			bool IsIdle();
+			bool IsRunning();
+			bool IsPaused(); 
+			bool IsStopped();
+
+			bool IsCurrent();
+
+			///
+			/// ִ��������С�
+			///
+			void Process();
+
+			const std::string& GetName();
+
+			///
+			/// �ص���
+			///
+			void Post();
+
+			///
+			/// ���ߺ���
+			///
+			void Sleep(uint ms);
+
+			///
+			/// ��������ʱ��
+			///
+			void SetSleepTime(uint ms);
+
+		private:
+
+			//----------------------------------------------------------------------------//
+
+			LUAX_DECL_ENUM(ThreadType);
+			LUAX_DECL_ENUM(ThreadState);
+
+			LUAX_DECL_METHOD(_New);
+			LUAX_DECL_METHOD(_AddTask);
+			LUAX_DECL_METHOD(_Start);
+			LUAX_DECL_METHOD(_Idle);
+			LUAX_DECL_METHOD(_Pause);
+			LUAX_DECL_METHOD(_Resume);
+			LUAX_DECL_METHOD(_Stop);
+			LUAX_DECL_METHOD(_Join);
+			LUAX_DECL_METHOD(_IsRunning);
+			LUAX_DECL_METHOD(_IsPaused);
+			LUAX_DECL_METHOD(_IsStopped);
+			LUAX_DECL_METHOD(_IsCurrent);
+			LUAX_DECL_METHOD(_Sleep);
+			LUAX_DECL_METHOD(_Post);
+			LUAX_DECL_METHOD(_GetName);
+			LUAX_DECL_METHOD(_GetType);
+			LUAX_DECL_METHOD(_GetState);
+			LUAX_DECL_METHOD(_SetSleepTime);
+
+			//----------------------------------------------------------------------------//
+
+			///
+			/// �˴������Ƿ����ػ�ģʽ��
+			///
+			bool mIsDaemon;
+
+			lua_State*  mLuaThread;
+
+			ThreadImpl* mImpl;
+			std::string mName;
+			ThreadType  mType;
+			uint        mSleepTime;
+
+			ThreadState mState;
+			Mutex       mStateMutex;
+
+			///
+			/// ͬ��������ص��ź���
+			///
+			Semaphore mSemPause;
+			Semaphore mSemResume;
+			Semaphore mSemStop;
+
+			///
+			/// ���������������
+			///
+			std::queue<Task*> mTaskQueue;
+			Mutex             mTaskQueueMutex;
+
+			/// 
+			/// �ӳ�ģʽʹ��
+			///
+			std::queue<Task*> mFinishedTasks;
+			Mutex             mFinishedMutex;
+
+			///
+			/// ����ģʽʹ�ã��ص�ʹ�õ�lua�߳�
+			///
+			lua_State*          mCallbackThread;
+			Luax::LuaxMemberRef mCallbackThreadRef;
+
+		};
+
+		///
+		/// �̵߳ľ���ʵ�֣����û���͸���ģ�һ��׼�������ֲ��ԣ�
+		///     1: win32 
+		///     2: posix
+		///     3: SDL 
+		///     4: std::thread
+		///
+		ASURA_ABSTRACT class ThreadImpl
+		{
+		public:
+			ThreadImpl() {};
+			virtual ~ThreadImpl() {};
+
+			virtual bool Start(Thread* thread, uint32 stacksize = 0) = 0;
+			virtual void Join() = 0;
+			virtual void Kill() = 0;
+
+			virtual void Sleep(uint ms) = 0;
+
+			virtual bool IsRunning() = 0;
+			virtual bool IsCurrent() = 0;
+
+		};
+
+	}
+}
+
+#endif
\ No newline at end of file