main.py
@@ -3,11 +3,14 @@ """ import multiprocessing import os import sys from db import redis_manager_delegate as redis_manager import huaxin_api.trade_client import huaxin_api.l2_client import huaxin_api.l1_client from log_module import log from server import * @@ -20,6 +23,7 @@ def createTradeServer(pipe_server, pipe_trade, pipe_l1, pipe_l2): log.close_print() # 初始化参数 global_data_loader.init() @@ -55,6 +59,7 @@ if __name__ == '__main__': log.close_print() # 策略与server间的通信 pss_server, pss_strategy = multiprocessing.Pipe() # 策略与交易间的通信