coalib.processes.LogPrinterThread

Complexity

Total Complexity

4

Size/Duplication

Total Lines	19
Duplicated Lines	0 %

import queue
class LogPrinterThread(threading.Thread):
    """
    This is the Thread object that outputs all log messages it gets from
    its message_queue. Setting obj.running = False will stop within the next
    0.1 seconds.
    """
    def __init__(self, message_queue, log_printer):
        threading.Thread.__init__(self)
        self.running = True
        self.message_queue = message_queue
        self.log_printer = log_printer

    def run(self):
        while self.running:
            try:
                elem = self.message_queue.get(timeout=0.1)
                self.log_printer.log_message(elem)
            except queue.Empty:
                pass