L2进程与策略进程合并

Administrator

2024-03-17 15199f8e93fe48e6261c99eadf6673d788db3a80

 l2/l2_data_listen_manager.py

@@ -8,6 +8,7 @@

import zmq

import constant
from log_module import async_log_util
from log_module.log import logger_debug

@@ -144,7 +145,8 @@
        t3 = threading.Thread(target=lambda: self.__recive_l2_markets(market_queue), daemon=True)
        t3.start()
        # 接收订单hosts
        self.__create_ipc_server_hosts(order_ipc_hosts)
        if not constant.is_windows():
            self.__create_ipc_server_hosts(order_ipc_hosts)

    def get_active_count(self, type_):
        expire_time = time.time() - 5