def run(self):
while True:<EOL><INDENT>msg = self._queue.get()<EOL>if msg is _SHUTDOWN:<EOL><INDENT>break<EOL><DEDENT>if self._enabled:<EOL><INDENT>print(msg)<EOL><DEDENT><DEDENT>
Process all log messages, until `stop()` is called. Intended to run
in its own thread.