Firepup650/bitbot-3.11-fork
2
0
Fork 0
Code Issues Pull requests Activity Actions

Put logging functionality on to it's own thread

Browse source
This commit is contained in:
jesopo 2018-12-10 13:18:15 +00:00
parent a3a88d4589
commit df8135f105
1 changed files with 12 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/Logging.py
View file

@ -1,4 +1,4 @@
import logging, logging.handlers, os, sys, time, typing import logging, logging.handlers, os, queue, sys, threading, time, typing
LEVELS = { LEVELS = {
"trace": logging.DEBUG-1, "trace": logging.DEBUG-1,
@ -54,6 +54,16 @@ class Log(object):
warn_handler.setFormatter(formatter) warn_handler.setFormatter(formatter)
self.logger.addHandler(warn_handler) self.logger.addHandler(warn_handler)
self._queue = queue.Queue()
self._thread = threading.Thread(target=self._loop)
self._thread.daemon = True
self._thread.start()
def _loop(self):
while True:
message, params, level, kwargs = self._queue.get(block=True)
self.logger.log(level, message, *params, **kwargs)
def trace(self, message: str, params: typing.List, **kwargs): def trace(self, message: str, params: typing.List, **kwargs):
self._log(message, params, LEVELS["trace"], kwargs) self._log(message, params, LEVELS["trace"], kwargs)
def debug(self, message: str, params: typing.List, **kwargs): def debug(self, message: str, params: typing.List, **kwargs):
@ -67,4 +77,4 @@ class Log(object):
def critical(self, message: str, params: typing.List, **kwargs): def critical(self, message: str, params: typing.List, **kwargs):
self._log(message, params, logging.CRITICAL, kwargs) self._log(message, params, logging.CRITICAL, kwargs)
def _log(self, message: str, params: typing.List, level: int, kwargs: dict): def _log(self, message: str, params: typing.List, level: int, kwargs: dict):
self.logger.log(level, message, *params, **kwargs) self._queue.put((message, params, level, kwargs))