2 # Repository abstraction for queuing |
2 # Repository abstraction for queuing |
3 # |
3 # |
4 |
4 |
5 import weakref |
5 import weakref |
6 import keyring |
6 import keyring |
|
7 import logging |
7 |
8 |
8 from . import loggers |
|
9 from . import config |
9 from . import config |
10 from .scheduler import QueueThread, QueuedEvent |
10 from .scheduler import QueueThread, QueuedEvent |
11 |
11 |
12 logger=loggers.get(__name__) |
12 logger=logging.getLogger(__name__) |
13 |
13 |
14 class FIFOEvent(QueuedEvent): |
14 class FIFOEvent(QueuedEvent): |
15 def __init__(self, cond, name=None): |
15 def __init__(self, cond, name=None): |
16 self._goodtogo=False |
16 self._goodtogo=False |
17 super().__init__(cond, name=name) |
17 super().__init__(cond, name=name) |