默认交易模式变更/真实下单位置计算位置修改

Administrator

5 分钟以前 2f2516749615da866e96d8d24e499b7ecbb63a3e

 log_module/async_log_util.py

@@ -13,13 +13,19 @@
class AsyncLogManager:

    def __init__(self):
        self.__log_queue = queue.Queue()
        self.__log_queue = queue.Queue(maxsize=10240)

    def __add_log(self, logger, method, *args):
        self.__log_queue.put_nowait((logger, time.time(), method, args))
        try:
            self.__log_queue.put_nowait((logger, time.time(), method, args))
        except Exception:
            pass

    def add_log(self, data):
        self.__log_queue.put_nowait(data)
        try:
            self.__log_queue.put_nowait(data)
        except Exception:
            pass

    def debug(self, logger, *args):
        self.__add_log(logger, "debug", *args)
@@ -36,9 +42,16 @@
    def exception(self, logger, *args):
        self.__add_log(logger, "exception", *args)

    def get_queue_size(self):
        """
        获取队列大小
        @return:
        """
        self.__log_queue.qsize()

    # 运行同步日志
    def run_sync(self, add_to_common_log=False):
        print("run_sync", add_to_common_log)
        # print("run_sync", add_to_common_log)
        logger_system.info(f"run_sync 线程ID:{tool.get_thread_id()}")
        while True:
            try:
@@ -91,10 +104,7 @@


if __name__ == "__main__":
    # info(logger_debug, "*-{}", "test")
    asyncLogManager = AsyncLogManager()
    asyncLogManager.info(logger_debug, "测试123")
    threading.Thread(target=lambda: asyncLogManager.run_sync(), daemon=True).start()
    time.sleep(1)
    # info(logger_debug, "002375")
    run_sync()
    _queue = queue.Queue(maxsize=102400)
    for i in range(200):
        _queue.put_nowait("1")