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))