| | |
|---|
| | | self.__subscribe(add_codes) |
|---|
| | | self.__unsubscribe(del_codes) |
|---|
| | | |
|---|
| | | if add_codes: |
|---|
| | | logger_system.info(f"新增L2订阅代码数量:{len(add_codes)}") |
|---|
| | | |
|---|
| | | # 设置最近的代码列表 |
|---|
| | | self.latest_codes_set = codes |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | if __name__ == '__main__': |
|---|
| | | logger_l2_trade.info("启动程序") |
|---|
| | | logger_system.info("启动程序") |
|---|
| | | logger_system.info("启动程序--------") |
|---|
| | | log.close_print() |
|---|
| | | # 策略与server间的通信 |
|---|
| | | pss_server, pss_strategy = multiprocessing.Pipe() |
|---|
| | |
|---|
| | | |
|---|
| | | # pipe的交易通道是否正常 |
|---|
| | | def is_pipe_channel_normal(): |
|---|
| | | return False #trade_pipe_channel_error_count < 3 |
|---|
| | | return trade_pipe_channel_error_count < 3 |
|---|
| | | |
|---|
| | | |
|---|
| | | # 测试交易通道 |
|---|
