import multiprocessing
import threading

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

if __name__ == '__main__':
    # l1交易
    queue_l1_trade_w_strategy_r = multiprocessing.Queue()
    queue_l1_trade_r_strategy_w = multiprocessing.Queue()

    queue_strategy_w_trade_r = multiprocessing.Queue()
    # 策略读交易写
    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,))
    l1TradeProcess.start()

    # 启动交易
    # 交易进程
    tradeProcess = multiprocessing.Process(
        target=trade_client.run,
        args=(queue_strategy_r_trade_w, queue_strategy_w_trade_r))
    tradeProcess.start()

    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)