| | |
|---|
| | | import huaxin_client.trade_client |
|---|
| | | import huaxin_client.l2_client |
|---|
| | | import huaxin_client.l1_client |
|---|
| | | import huaxin_client.l1_client_for_trade |
|---|
| | | from huaxin_client import l2_market_client |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | l1Process = multiprocessing.Process(target=huaxin_client.l1_client.run, |
|---|
| | | args=(queue_l1_w_strategy_r, queue_l1_r_strategy_w,)) |
|---|
| | | l1Process.start() |
|---|
| | | |
|---|
| | | l1TradeProcess = multiprocessing.Process(target=huaxin_client.l1_client_for_trade.run, |
|---|
| | | 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,)) |
|---|
