aboutsummaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
Diffstat (limited to 'lib')
-rw-r--r--lib/__init__.py0
-rw-r--r--lib/worker.py23
2 files changed, 23 insertions, 0 deletions
diff --git a/lib/__init__.py b/lib/__init__.py
new file mode 100644
index 0000000..e69de29
--- /dev/null
+++ b/lib/__init__.py
diff --git a/lib/worker.py b/lib/worker.py
new file mode 100644
index 0000000..a3ee435
--- /dev/null
+++ b/lib/worker.py
@@ -0,0 +1,23 @@
+import threading
+import time
+
+def name():
+ return threading.currentThread().getName()
+
+def worker(q):
+ while True:
+ part = q.get()
+
+ if part is None:
+ break
+
+ do_work(part)
+ time.sleep(0.05)
+ q.task_done()
+
+def do_work(part: dict):
+ if part['type'] == "print":
+ action_print(part['payload'])
+
+def action_print(text: str):
+ print('{0} - {1}'.format(name(), text))