| 52:aef860e99323 | 53:442c558bd632 |
|---|---|
| 1 # | |
| 2 # Repository abstraction for queuing | |
| 3 # | |
| 4 | |
| 5 from scheduler import TerminableThread, QueuedEvent | |
| 6 | |
| 7 class Repository(TerminableThread): | |
| 8 def __init__(self) | |
| 9 self.__next_event_time = None | |
| 10 self.__list = None | |
| 11 self._cond = Condition() | |
| 12 self._terminate = False | |
| 13 super().__init__(target = self.__scheduler_thread, name = 'Scheduler') | |
| 14 self.daemon=True |