summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/LuaTask.cc46
1 files changed, 46 insertions, 0 deletions
diff --git a/src/LuaTask.cc b/src/LuaTask.cc
new file mode 100644
index 0000000..754de6f
--- /dev/null
+++ b/src/LuaTask.cc
@@ -0,0 +1,46 @@
+#include "LuaTask.h"
+#include "Main.h"
+#include "TaskMan.h"
+
+void Balau::LuaMainTask::exec(LuaExecCell * cell) {
+ m_queue.push(cell);
+ m_queueEvent.trigger();
+}
+
+void Balau::LuaMainTask::stop() {
+ Atomic::CmpXChgVal(&m_stopping, true, false);
+ m_queueEvent.trigger();
+}
+
+void Balau::LuaMainTask::Do() {
+ while (!m_stopping) {
+ waitFor(&m_queueEvent);
+
+ LuaExecCell * cell;
+ while ((cell = m_queue.pop(false))) {
+ createTask(new LuaTask(L.thread(), cell));
+ }
+
+ yield();
+ }
+}
+
+void Balau::LuaTask::Do() {
+ m_cell->run(L);
+ if (m_cell->m_detached)
+ delete m_cell;
+ else
+ m_cell->m_event.trigger();
+}
+
+void Balau::LuaExecCell::exec(LuaMainTask * mainTask) {
+ if (!m_detached)
+ Task::prepare(&m_event);
+ mainTask->exec(this);
+ if (!m_detached)
+ Task::yield(&m_event);
+}
+
+void Balau::LuaExecString::run(Lua & L) {
+ L.load(m_str);
+}