From 49c83f0c693890f1e2df33919606362890bf726d Mon Sep 17 00:00:00 2001 From: ngharo Date: Thu, 28 Jun 2018 23:35:32 -0500 Subject: WIP --- lib/worker.py | 23 +++++++++++++++++++++++ 1 file changed, 23 insertions(+) create mode 100644 lib/worker.py (limited to 'lib/worker.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)) -- cgit v1.2.3