| | |
| | | # -*- coding: utf-8 -*- |
| | | import json |
| | | import logging |
| | | import os |
| | | import queue |
| | | import threading |
| | | import time |
| | |
| | | from huaxin_api.command_manager import L2ActionCallback |
| | | from log_module import log |
| | | from log_module.log import logger_local_huaxin_l2_subscript, logger_local_huaxin_l2_orderdetail, \ |
| | | logger_local_huaxin_l2_transaction |
| | | logger_local_huaxin_l2_transaction, logger_system |
| | | |
| | | Front_Address = "tcp://10.0.1.101:6900" |
| | | Multicast_Address = "udp://224.224.2.19:7889" |
| | |
| | | |
| | | |
| | | def run(pipe_trade, pipe_strategy): |
| | | logger_system.info("L2进程ID:", os.getpid()) |
| | | log.close_print() |
| | | if pipe_trade is not None: |
| | | t1 = threading.Thread(target=lambda: __receive_from_pipe_trade(pipe_trade), daemon=True) |