线程ID记录

Administrator

2023-09-14 a29622874377f194aa83b5c51422d7ce5516bd9c

 huaxin_client/l2_data_manager.py

@@ -15,7 +15,8 @@
from huaxin_client.l2_data_transform_protocol import L2DataCallBack
from log_module import log_export, async_log_util
from log_module.log import logger_local_huaxin_l2_error, logger_local_huaxin_l2_upload, logger_local_huaxin_l2_buy_no, \
    logger_local_huaxin_g_cancel, hx_logger_contact_debug
    logger_local_huaxin_g_cancel, hx_logger_contact_debug, logger_system
from utils import tool

order_detail_upload_active_time_dict = {}
transaction_upload_active_time_dict = {}
@@ -229,6 +230,7 @@

def __run_upload_common(l2_data_callback: L2DataCallBack):
    print("__run_upload_common")
    logger_system.info(f"l2_client __run_upload_common 线程ID:{tool.get_thread_id()}")
    while True:
        try:
            while not common_queue.empty():
@@ -247,6 +249,7 @@

def __run_upload_trading_canceled(l2_data_callback: L2DataCallBack):
    print("__run_upload_trading_canceled")
    logger_system.info(f"l2_client __run_upload_trading_canceled 线程ID:{tool.get_thread_id()}")
    while True:
        try:
            temp = trading_canceled_queue.get()
@@ -262,6 +265,7 @@

def __run_log():
    print("__run_log")
    logger_system.info(f"l2_client __run_log 线程ID:{tool.get_thread_id()}")
    while True:
        try:
            temp = log_buy_no_queue.get()
@@ -316,6 +320,7 @@
# 运行守护线程
def run_upload_daemon(_l2_data_callback):
    def upload_daemon():
        logger_system.info(f"l2_client upload_daemon 线程ID:{tool.get_thread_id()}")
        while True:
            try:
                for code in target_codes_add_time: