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)
|
