(self)
| 180 | thread.join() |
| 181 | |
| 182 | def test_queue_task_done(self): |
| 183 | # Test to make sure a queue task completed successfully. |
| 184 | q = self.type2test() |
| 185 | try: |
| 186 | q.task_done() |
| 187 | except ValueError: |
| 188 | pass |
| 189 | else: |
| 190 | self.fail("Did not detect task count going negative") |
| 191 | |
| 192 | def test_queue_join(self): |
| 193 | # Test that a queue join()s successfully, and before anything else |