线程日志

Administrator

2023-09-12 2cfa8edcbdb30d13b0f0e6d57d2f922b46ed8710

线程日志

 db/redis_manager_delegate.py

@@ -3,6 +3,7 @@
"""
import logging
import queue
import threading
import time

import redis
@@ -195,6 +196,7 @@
    @classmethod
    def run_loop(cls):
        logger_system.info("启动Redis数据同步服务")
        logger_system.debug(f"线程ID，redis：{threading.get_ident()}")
        dataList = []
        last_upload_time = time.time()
        while True:

 huaxin_client/l2_client.py

@@ -574,6 +574,7 @@


def run(pipe_trade, _pipe_strategy, _l2_data_callback: l2_data_transform_protocol.L2DataCallBack)->None:
    logger_system.debug(f"线程ID，l2_client：{threading.get_ident()}")
    logger_system.info("L2进程ID：{}", os.getpid())
    try:
        log.close_print()

 huaxin_client/trade_client.py

@@ -1113,6 +1113,7 @@

def run(trade_response_: TradeResponse, pipe_l2=None, pipe_strategy=None):
    try:
        logger_system.debug(f"线程ID，trade_client：{threading.get_ident()}")
        logger_system.info("交易进程ID：{}", os.getpid())
        __init_trade_data_server()
        global l2pipe

 main.py

@@ -69,6 +69,7 @@


def createDataServer():
    logger_system.debug(f"线程ID，dataServer：{threading.get_ident()}")
    logger_system.info("create DataServer")
    tcpserver = data_server.run("", 9004)
    tcpserver.serve_forever()

 test/test.py

@@ -9,30 +9,7 @@

__queue = queue.Queue()


def read(pipe):
    while True:
        if not __queue.empty():
            val = __queue.get(block=False)
            if val:
                print("read:", val)


def write(pipe):
    while True:
        __queue.put_nowait("123")
        time.sleep(1)
        break


if __name__ == "__main__":
    p1, p2 = multiprocessing.Pipe()
    t1 = threading.Thread(target=lambda: write(p1), daemon=True)
    t1.start()
    print("是否alive：", t1.is_alive())

    threading.Thread(target=lambda: read(p2), daemon=True).start()
    while True:
        print("是否alive：", t1.is_alive())
        time.sleep(1)
    input()
        data = __queue.get()
        print("数据：", data)

 trade/huaxin/trade_api_server.py

@@ -500,6 +500,7 @@


def run(pipe_server, pipe_l2):
    logger_system.debug(f"线程ID，trade_api_server：{threading.get_ident()}")
    logger_system.info("create TradeApiServer")
    # 拉取交易信息
    huaxin_trade_data_update.run()

 trade/huaxin/trade_server.py

@@ -821,6 +821,7 @@

def run(pipe_trade, pipe_l1, pipe_l2, trade_cmd_callback):
    try:
        logger_system.debug(f"线程ID，trade_server：{threading.get_ident()}")
        # 执行一些初始化数据
        block_info.init()