There is no need to wait for each worker thread individually.
Instead we send all worker threads the shutdown signal and
wait after that until they all have finished.
Signed-off-by: Michael Tremer <michael.tremer@ipfire.org>
def shutdown(self):
self.running = False
def shutdown(self):
self.running = False
- # Wait until all data has been written.
- self.join()
-
class WriteQueue(threading.Thread):
def __init__(self, collecty, submit_interval):
class WriteQueue(threading.Thread):
def __init__(self, collecty, submit_interval):