持仓L2订阅

Administrator

2024-03-28 af7d9b55cad79aa7ade0b02802a26ebeb742c297

 main.py

@@ -1,6 +1,7 @@
import multiprocessing
import threading

from huaxin_client import l1_client_for_trade, trade_client
from huaxin_client import l1_client_for_trade, trade_client, l2_client
from trade import trade_strategy
import huaxin_client

@@ -13,6 +14,8 @@
    # 策略读交易写
    queue_strategy_r_trade_w = multiprocessing.Queue()

    queue_strategy_w_l2_r = multiprocessing.Queue()

    # 启动L1
    l1TradeProcess = multiprocessing.Process(target=l1_client_for_trade.run,
                                             args=(queue_l1_trade_w_strategy_r, queue_l1_trade_r_strategy_w,))
@@ -24,4 +27,9 @@
        target=trade_client.run,
        args=(queue_strategy_r_trade_w, queue_strategy_w_trade_r))
    tradeProcess.start()
    trade_strategy.run(queue_l1_trade_w_strategy_r, queue_l1_trade_r_strategy_w, queue_strategy_r_trade_w, queue_strategy_w_trade_r)

    trade_strategy.init_l2_data_callbacks()
    threading.Thread(target=lambda: l2_client.run(queue_strategy_w_l2_r, trade_strategy.l2_data_callbacks),
                     daemon=True).start()
    trade_strategy.run(queue_l1_trade_w_strategy_r, queue_l1_trade_r_strategy_w, queue_strategy_r_trade_w,
                       queue_strategy_w_trade_r,queue_strategy_w_l2_r)