| | |
|---|
| | | |
|---|
| | | def createTradeServer(pipe_server, queue_strategy_r_trade_w_: multiprocessing.Queue, |
|---|
| | | queue_l1_w_strategy_r_: multiprocessing.Queue, |
|---|
| | | queue_strategy_w_trade_r_: multiprocessing.Queue, order_queues_, transaction_queues_, market_queue_): |
|---|
| | | queue_strategy_w_trade_r_: multiprocessing.Queue, order_queues_, transaction_queues_, |
|---|
| | | market_queue_): |
|---|
| | | logger_system.info("策略进程ID：{}", os.getpid()) |
|---|
| | | log.close_print() |
|---|
| | | # 初始化参数 |
|---|
| | |
|---|
| | | logger_system.error(f"端口服务器：{9004} 启动失败") |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main__1': |
|---|
| | | huaxin_client.l2_client.test() |
|---|
| | | |
|---|
| | | if __name__ == '__main__': |
|---|
| | | try: |
|---|
| | | logger_l2_trade.info("启动程序") |
|---|
