| | |
|---|
| | | t1.start() |
|---|
| | | # |
|---|
| | | # 启动华鑫交易服务 |
|---|
| | | t1 = threading.Thread( |
|---|
| | | target=lambda: trade_server.run(pipe_trade, pipe_l1, pipe_l2, huaxin_client.trade_client.process_cmd), |
|---|
| | | name="trade_server", daemon=True) |
|---|
| | | t1.start() |
|---|
| | | |
|---|
| | | huaxin_client.trade_client.run(trade_server.my_trade_response, ptl2_trade, pst_trade) |
|---|
| | | trade_server.run(pipe_trade, pipe_l1, pipe_l2, huaxin_client.trade_client.process_cmd) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 主服务 |
|---|
| | |
|---|
| | | l1Process = multiprocessing.Process(target=huaxin_client.l1_client.run, args=(pl1t_l1,)) |
|---|
| | | l1Process.start() |
|---|
| | | |
|---|
| | | # 交易进程 |
|---|
| | | tradeProcess = multiprocessing.Process( |
|---|
| | | target=lambda: huaxin_client.trade_client.run(None, ptl2_trade, pst_trade)) |
|---|
| | | tradeProcess.start() |
|---|
| | | |
|---|
| | | # 主进程 |
|---|
| | | createTradeServer(pss_strategy, pst_strategy, pl1t_strategy, psl2_strategy, ptl2_l2, psl2_l2, ptl2_trade, |
|---|
| | | pst_trade) |
|---|
| | | |
|---|
| | | # 将tradeServer作为主进程 |
|---|
| | | l1Process.join() |
|---|
| | | tradeProcess.join() |
|---|
| | | except Exception as e: |
|---|
| | | logger_system.exception(e) |
|---|
