modules/fm-orchestrator
1
0
Fork 0
mirror of https://pagure.io/fm-orchestrator.git synced 2026-04-05 11:48:33 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix #211: stay attached to the main thread to keep control (foreground mode)

Browse Source
This commit is contained in:
Filip Valder
2016-12-09 12:35:44 +01:00
parent adbdc29545
commit 5d8a728d89
1 changed files with 15 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
module_build_service/scheduler/main.py
View File

@@ -317,21 +317,22 @@ def main(initial_msgs=[], return_after_build=False):
for msg in initial_msgs:
outgoing_work_queue_put(msg)
# This ingest thread puts work on the queue
messaging_thread = MessageIngest(_work_queue, return_after_build)
# This poller does other work, but also sometimes puts work in queue.
polling_thread = Poller(_work_queue)
# This worker takes work off the queue and handles it.
worker_thread = MessageWorker(_work_queue, return_after_build)
messaging_thread.start()
polling_thread.start()
worker_thread.start()
try:
# This ingest thread puts work on the queue
messaging_thread = MessageIngest(_work_queue, return_after_build)
# This poller does other work, but also sometimes puts work in queue.
polling_thread = Poller(_work_queue)
# This worker takes work off the queue and handles it.
worker_thread = MessageWorker(_work_queue, return_after_build)
messaging_thread.start()
polling_thread.start()
worker_thread.start()
worker_thread.join()
polling_thread.stop = True
while worker_thread.is_alive():
time.sleep(3)
except KeyboardInterrupt:
# FIXME: Make this less brutal
os._exit(0)
finally:
polling_thread.stop = True