import multiprocessing
import threading

import middle_server
from huaxin_client import huaxin_trade_client
from log_module import async_log_util
from trade import huaxin_trade_api

if __name__ == "__main__":
    # 运行仿真交易
    queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query = multiprocessing.Queue(), multiprocessing.Queue(), multiprocessing.Queue()
    huaxin_trade_api.run_trade(queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query)

    # ===========运行交易端==========
    tradeProcess = multiprocessing.Process(
        target=huaxin_trade_client.run,
        args=(queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query, queue_strategy_r_trade_w,))
    tradeProcess.start()

    threading.Thread(target=async_log_util.run_sync, daemon=True).start()

    middle_server.run(10020)