(self, event_engine, clock_engine, watch_stocks=None, s='sina')
| 19 | PushInterval = 15 |
| 20 | |
| 21 | def __init__(self, event_engine, clock_engine, watch_stocks=None, s='sina'): |
| 22 | |
| 23 | self.watch_stocks = watch_stocks |
| 24 | self.s = s |
| 25 | self.source = None |
| 26 | self.__queue = mp.Queue(1000) |
| 27 | self.is_pause = not clock_engine.is_tradetime_now() |
| 28 | self._control_thread = Thread(target=self._process_control, name="FixedDataEngine._control_thread") |
| 29 | self._control_thread.start() |
| 30 | super(FixedDataEngine, self).__init__(event_engine, clock_engine) |
| 31 | |
| 32 | def _process_control(self): |
| 33 |
nothing calls this directly
no test coverage detected