for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
import queue
import threading
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
coala-analyzer /
coala
