(self, fn, args)
| 25 | # A thread to run a function that unclogs a blocked Queue. |
| 26 | class _TriggerThread(threading.Thread): |
| 27 | def __init__(self, fn, args): |
| 28 | self.fn = fn |
| 29 | self.args = args |
| 30 | self.startedEvent = threading.Event() |
| 31 | threading.Thread.__init__(self) |
| 32 | |
| 33 | def run(self): |
| 34 | # The sleep isn't necessary, but is intended to give the blocking |