strix

commit 60515f688f4bfa4a8ad5fdc8625f02a77eea1573
parent 9cfa9aa1c80106f0a1b4bebcef9212e32e868f3a
Author: Brian C. Lane <bcl@brianlane.com>
Date:   Sat, 25 Apr 2020 16:06:28 -0700

Use JoinableQueue for logging_queue

Diffstat:
M
src/strix/__init__.py
 | 
4
++--

1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/strix/__init__.py b/src/strix/__init__.py
@@ -102,8 +102,8 @@ def run() -> bool:
         return False
 
     # Start logging thread
-    logging_queue = mp.Queue()      # type: mp.Queue[List[Any]]
-    logging_quit = mp.Event()       # type: mp.Event
+    logging_queue = mp.JoinableQueue()  # type: mp.JoinableQueue[List[Any]]
+    logging_quit = mp.Event()           # type: mp.Event
     logging_thread = mp.Process(name="logging-thread",
                                 target=logger.listener,
                                 args=(logging_queue, logging_quit, opts.log))