From 49c83f0c693890f1e2df33919606362890bf726d Mon Sep 17 00:00:00 2001 From: ngharo Date: Thu, 28 Jun 2018 23:35:32 -0500 Subject: WIP --- spawn.py | 29 +++++++++++++++++++++++++++++ 1 file changed, 29 insertions(+) create mode 100644 spawn.py (limited to 'spawn.py') diff --git a/spawn.py b/spawn.py new file mode 100644 index 0000000..decea85 --- /dev/null +++ b/spawn.py @@ -0,0 +1,29 @@ +import sys +import queue +import threading +from lib import worker + +num_worker_threads = 4 + +def input(): + return sys.stdin + +q = queue.Queue() +threads = [] +for i in range(num_worker_threads): + thread_name = 'bob-' + str(i) + t = threading.Thread(target=worker.worker, args=(q,), name=thread_name) + t.start() + threads.append(t) + +for item in input(): + q.put(item) + +# block until all tasks are done +q.join() + +# stop workers +for i in range(num_worker_threads): + q.put(None) +for t in threads: + t.join() -- cgit v1.2.3