| | |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
| | | print(os.getpid()) |
|---|
| | | close_print() |
|---|
| | | logger_local_huaxin_l1.info("测试") |
|---|
| | | input() |
|---|
| | |
|---|
| | | import huaxin_api.l2_client |
|---|
| | | import huaxin_api.l1_client |
|---|
| | | from log_module import log |
|---|
| | | from log_module.log import logger_l2_trade, logger_system |
|---|
| | | from log_module.log import logger_l2_trade, logger_system, logger_local_huaxin_l1 |
|---|
| | | |
|---|
| | | from server import * |
|---|
| | | |
|---|
| | |
|---|
| | | tradeProcess = multiprocessing.Process(target=huaxin_api.trade_client.run, args=(ptl2_trade, pst_trade,)) |
|---|
| | | tradeProcess.start() |
|---|
| | | # L1订阅数据 |
|---|
| | | huaxin_api.l1_client.run_async(pl1t_l1) |
|---|
| | | huaxin_api.l1_client.run(pl1t_l1) |
|---|
| | | # 将tradeServer作为主进程 |
|---|
| | | tradeServerProcess.join() |
|---|
| | | tradeProcess.join() |
|---|
