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