From f5e72dd12fc47f082a4f6d14090391410aa8a9f1 Mon Sep 17 00:00:00 2001 From: chai Date: Mon, 6 Aug 2018 21:50:55 +0800 Subject: *update --- src/libjin/Thread/Thread.cpp | 5 ----- src/libjin/Thread/Thread.h | 1 + src/libjin/thread/thread.cpp | 5 ----- src/libjin/thread/thread.h | 1 + src/lua/thread/luaopen_Thread.cpp | 8 +++++--- 5 files changed, 7 insertions(+), 13 deletions(-) (limited to 'src') diff --git a/src/libjin/Thread/Thread.cpp b/src/libjin/Thread/Thread.cpp index ae6498d..06975f7 100644 --- a/src/libjin/Thread/Thread.cpp +++ b/src/libjin/Thread/Thread.cpp @@ -23,7 +23,6 @@ namespace thread friend class Conditional; }; - // 条件变量线程间signal wait class Conditional { public: @@ -44,19 +43,15 @@ namespace thread Lock(Mutex* m) : mutex(m) { mutex->lock(); } - Lock(Mutex& m) : mutex(&m) { mutex->lock(); } - ~Lock() { mutex->unlock(); } private: Mutex* mutex; - Lock(Lock&) {} - }; ////////////////////////////////////////////////////////////////////// diff --git a/src/libjin/Thread/Thread.h b/src/libjin/Thread/Thread.h index e271fc9..4996705 100644 --- a/src/libjin/Thread/Thread.h +++ b/src/libjin/Thread/Thread.h @@ -82,6 +82,7 @@ namespace thread private: std::map share; // threads shared value + std::map sharevalue; }; public: diff --git a/src/libjin/thread/thread.cpp b/src/libjin/thread/thread.cpp index ae6498d..06975f7 100644 --- a/src/libjin/thread/thread.cpp +++ b/src/libjin/thread/thread.cpp @@ -23,7 +23,6 @@ namespace thread friend class Conditional; }; - // 条件变量线程间signal wait class Conditional { public: @@ -44,19 +43,15 @@ namespace thread Lock(Mutex* m) : mutex(m) { mutex->lock(); } - Lock(Mutex& m) : mutex(&m) { mutex->lock(); } - ~Lock() { mutex->unlock(); } private: Mutex* mutex; - Lock(Lock&) {} - }; ////////////////////////////////////////////////////////////////////// diff --git a/src/libjin/thread/thread.h b/src/libjin/thread/thread.h index e271fc9..4996705 100644 --- a/src/libjin/thread/thread.h +++ b/src/libjin/thread/thread.h @@ -82,6 +82,7 @@ namespace thread private: std::map share; // threads shared value + std::map sharevalue; }; public: diff --git a/src/lua/thread/luaopen_Thread.cpp b/src/lua/thread/luaopen_Thread.cpp index f811bdf..c08c262 100644 --- a/src/lua/thread/luaopen_Thread.cpp +++ b/src/lua/thread/luaopen_Thread.cpp @@ -1,5 +1,6 @@ #include "lua/luax.h" #include "libjin/jin.h" +#include "../luaopen_jin.h" #include "../luaopen_types.h" namespace jin @@ -36,9 +37,8 @@ namespace jin Thread* thread = (Thread*)p; lua_State* L = lua_open(); luax_openlibs(L); - luaopen_thread(L); - luax_dostring(L, thread->code.c_str(), thread->code.length(),thread->name.c_str()); - + luaopen_jin(L); + luax_dostring(L, thread->code.c_str()); } static int l_gc(lua_State* L) @@ -117,6 +117,8 @@ namespace jin static int l_demand(lua_State* L) { + Thread* t = checkThread(L); + return 1; } -- cgit v1.1-26-g67d0