| | |
| | | import huaxin_client.l2_client |
| | | import huaxin_client.l1_client |
| | | import huaxin_client.l1_client_for_trade |
| | | from huaxin_client import l2_market_client |
| | | from log_module import log |
| | | from log_module.log import logger_l2_trade, logger_system, logger_local_huaxin_l1 |
| | | |
| | |
| | | args=(queue_l1_trade_w_strategy_r, queue_l1_trade_r_strategy_w,)) |
| | | l1TradeProcess.start() |
| | | |
| | | l2MarketProcess = multiprocessing.Process(target=l2_market_client.run, |
| | | args=(queue_l1_w_strategy_r,)) |
| | | l2MarketProcess.start() |
| | | |
| | | # 交易进程 |
| | | tradeProcess = multiprocessing.Process( |
| | | target=huaxin_client.trade_client.run, |