| | |
|---|
| | | import multiprocessing |
|---|
| | | |
|---|
| | | from db import redis_manager_delegate as redis_manager |
|---|
| | | from log_module.log import logger_l2_process_time |
|---|
| | | |
|---|
| | | from server import * |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | serverProcess = multiprocessing.Process(target=createServer, args=(pss_server,)) |
|---|
| | | serverProcess.start() |
|---|
| | | # 将tradeServer作为主进程 |
|---|
| | | createTradeServer(pss_strategy, pst_strategy, pl1t_trade) |
|---|
| | | |
|---|
| | | # 交易进程与L2进程 |
|---|
| | | tradeProcess = multiprocessing.Process(target=huaxin.trade_client.run, args=(ptl2_trade, pst_trade)) |
|---|
| | | l2Process = multiprocessing.Process(target=huaxin.l2_client.run, args=(ptl2_l2,)) |
|---|
| | | tradeProcess.start() |
|---|
| | | l2Process.start() |
|---|
| | | # L1订阅数据 |
|---|
| | | huaxin.l1_client.run_async(pl1t_l1) |
|---|
| | | # 将tradeServer作为主进程 |
|---|
| | | createTradeServer(pss_strategy, pst_strategy, pl1t_trade) |
|---|
