(self)
| 6421 | parent_can_continue.set() |
| 6422 | |
| 6423 | def test_empty_exceptions(self): |
| 6424 | # Assert that checking emptiness of a closed queue raises |
| 6425 | # an OSError, independently of whether the queue was used |
| 6426 | # or not. This differs from Queue and JoinableQueue. |
| 6427 | q = multiprocessing.SimpleQueue() |
| 6428 | q.close() # close the pipe |
| 6429 | with self.assertRaisesRegex(OSError, 'is closed'): |
| 6430 | q.empty() |
| 6431 | |
| 6432 | @warnings_helper.ignore_fork_in_thread_deprecation_warnings() |
| 6433 | def test_empty(self): |
nothing calls this directly
no test coverage detected