Merge heads.
This commit is contained in:
commit
ac982d752d
|
@ -43,6 +43,9 @@ class _TriggerThread(threading.Thread):
|
||||||
|
|
||||||
class BlockingTestMixin:
|
class BlockingTestMixin:
|
||||||
|
|
||||||
|
def tearDown(self):
|
||||||
|
self.t = None
|
||||||
|
|
||||||
def do_blocking_test(self, block_func, block_args, trigger_func, trigger_args):
|
def do_blocking_test(self, block_func, block_args, trigger_func, trigger_args):
|
||||||
self.t = _TriggerThread(trigger_func, trigger_args)
|
self.t = _TriggerThread(trigger_func, trigger_args)
|
||||||
self.t.start()
|
self.t.start()
|
||||||
|
@ -222,7 +225,7 @@ class FailingQueue(Queue.Queue):
|
||||||
raise FailingQueueException, "You Lose"
|
raise FailingQueueException, "You Lose"
|
||||||
return Queue.Queue._get(self)
|
return Queue.Queue._get(self)
|
||||||
|
|
||||||
class FailingQueueTest(unittest.TestCase, BlockingTestMixin):
|
class FailingQueueTest(BlockingTestMixin, unittest.TestCase):
|
||||||
|
|
||||||
def failing_queue_test(self, q):
|
def failing_queue_test(self, q):
|
||||||
if not q.empty():
|
if not q.empty():
|
||||||
|
|
Loading…
Reference in New Issue