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 |