Commit ec9bccd0 authored by Denis Bilenko's avatar Denis Bilenko

test_queue.py: re-enable tests for JoinableQueue

parent d7ee03c0
...@@ -160,9 +160,10 @@ class BaseQueueTest(unittest.TestCase, BlockingTestMixin): ...@@ -160,9 +160,10 @@ class BaseQueueTest(unittest.TestCase, BlockingTestMixin):
q.put(None) # instruct the threads to close q.put(None) # instruct the threads to close
q.join() # verify that you can join twice q.join() # verify that you can join twice
def DISABLE_test_queue_task_done(self): def test_queue_task_done(self):
# Test to make sure a queue task completed successfully. # Test to make sure a queue task completed successfully.
q = self.type2test() q = Queue.JoinableQueue() # self.type2test()
# XXX the same test in subclasses
try: try:
q.task_done() q.task_done()
except ValueError: except ValueError:
...@@ -170,10 +171,11 @@ class BaseQueueTest(unittest.TestCase, BlockingTestMixin): ...@@ -170,10 +171,11 @@ class BaseQueueTest(unittest.TestCase, BlockingTestMixin):
else: else:
self.fail("Did not detect task count going negative") self.fail("Did not detect task count going negative")
def DISABLE_test_queue_join(self): def test_queue_join(self):
# Test that a queue join()s successfully, and before anything else # Test that a queue join()s successfully, and before anything else
# (done twice for insurance). # (done twice for insurance).
q = self.type2test() q = Queue.JoinableQueue() # self.type2test()
# XXX the same test in subclass
self.queue_join_test(q) self.queue_join_test(q)
self.queue_join_test(q) self.queue_join_test(q)
try: try:
......
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