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