From 6551adeca70d4299a99d45245d4e13dbfdfa87e5 Mon Sep 17 00:00:00 2001
From: chai <chaifix@163.com>
Date: Tue, 23 Oct 2018 15:56:01 +0800
Subject: =?UTF-8?q?*=E4=BF=AE=E6=94=B9lua=E7=BB=91=E5=AE=9A=E6=96=87?=
 =?UTF-8?q?=E4=BB=B6=E7=9A=84=E6=96=87=E4=BB=B6=E5=90=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/lua/modules/thread/je_lua_thread.h | 94 ++++++++++++++++++++++++++++++++++
 1 file changed, 94 insertions(+)
 create mode 100644 src/lua/modules/thread/je_lua_thread.h

(limited to 'src/lua/modules/thread/je_lua_thread.h')

diff --git a/src/lua/modules/thread/je_lua_thread.h b/src/lua/modules/thread/je_lua_thread.h
new file mode 100644
index 0000000..60d588a
--- /dev/null
+++ b/src/lua/modules/thread/je_lua_thread.h
@@ -0,0 +1,94 @@
+#include "libjin/jin.h"
+#include "lua/common/common.h"
+
+namespace JinEngine
+{
+    namespace Lua
+    {
+        namespace thread
+        {
+
+            class Thread
+            {
+            public:
+                typedef JinEngine::MultiThread::Thread::Variant Variant;
+                typedef JinEngine::MultiThread::Thread::ThreadRunner ThreadRunner;
+
+                Thread(std::string _name, std::string _code, ThreadRunner runner)
+                    : name(_name)
+                    , code(_code)
+                {
+                    thread = new JinEngine::MultiThread::Thread(_name, runner);
+                }
+
+		        ~Thread()
+		        {
+			        delete thread;
+		        }
+
+                bool start(void* p)
+                {
+                    return thread->start(p);
+                }
+
+                void wait()
+                {
+                    thread->wait();
+                }
+
+                void send(int slot, const Variant& value)
+                {
+                    thread->send(slot, value);
+                }
+
+                bool receive(int slot)
+                {
+                    return thread->receive(slot);
+                }
+
+                Variant fetch(int slot)
+                {
+                    return thread->fetch(slot);
+                }
+
+                Variant demand(int slot)
+                {
+                    return thread->demand(slot);
+                }
+
+                void remove(int slot)
+                {
+                    thread->remove(slot);
+                }
+
+                const char* getName()
+                {
+                    return name.c_str();
+                }
+
+                bool isRunning()
+                {
+                    return thread->isRunning();
+                }
+
+                void lock()
+                {
+                    thread->lock();
+                }
+
+                void unlock()
+                {
+                    thread->unlock();
+                }
+
+                const std::string name;
+                const std::string code;
+
+	        private:
+                JinEngine::MultiThread::Thread* thread;
+
+            };
+
+        } // thread
+    } // namespace Lua
+} // namespace JinEngine
\ No newline at end of file
-- 
cgit v1.1-26-g67d0