event_source.py 文件源码

def __init__(self, fps, mod_config):
        self._env = Environment.get_instance()
        self.mod_config = mod_config
        self.fps = fps
        self.event_queue = Queue()

        self.before_trading_fire_date = datetime.date(2000, 1, 1)
        self.after_trading_fire_date = datetime.date(2000, 1, 1)
        self.settlement_fire_date = datetime.date(2000, 1, 1)

        if not mod_config.redis_uri:
            self.quotation_engine_thread = Thread(target=self.quotation_worker)
            self.quotation_engine_thread.daemon = True

        self.clock_engine_thread = Thread(target=self.clock_worker)
        self.clock_engine_thread.daemon = True