"""
异步日志管理器
"""
import queue

from log_module.log import logger_debug

log_queue = queue.Queue()


def __add_log(logger, method, *args):
    log_queue.put_nowait((logger, method, args))


def debug(logger, *args):
    __add_log(logger, "debug", *args)


def info(logger, *args):
    __add_log(logger, "info", *args)


def warning(logger, *args):
    __add_log(logger, "warning", *args)


def error(logger, *args):
    __add_log(logger, "error", *args)


def exception(logger, *args):
    __add_log(logger, "exception", *args)


# 运行同步日志
def run_sync():
    while True:
        try:
            val = log_queue.get()
            cmd = val[1]
            method = getattr(val[0], cmd)
            method(*val[2])
        except:
            pass


if __name__ == "__main__":
    logger_debug.warning()
    info(logger_debug, "*-{}", "test")
    run_sync()