Commit 85b81c60 authored by Jeremy Hylton's avatar Jeremy Hylton

Override join() to provide a timeout.

parent ad2ba5d4
...@@ -32,6 +32,11 @@ class BasicThread(threading.Thread): ...@@ -32,6 +32,11 @@ class BasicThread(threading.Thread):
self.gotValueError = 0 self.gotValueError = 0
self.gotDisconnected = 0 self.gotDisconnected = 0
threading.Thread.__init__(self) threading.Thread.__init__(self)
self.setDaemon(1)
def join(self):
threading.Thread.join(self, 10)
assert not self.isAlive()
class GetsThroughVoteThread(BasicThread): class GetsThroughVoteThread(BasicThread):
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment