(self)
| 157 | pass |
| 158 | |
| 159 | def _terminate_broken(self): |
| 160 | # Close a Queue on error. |
| 161 | |
| 162 | # gh-94777: Prevent queue writing to a pipe which is no longer read. |
| 163 | self._reader.close() |
| 164 | |
| 165 | # gh-107219: Close the connection writer which can unblock |
| 166 | # Queue._feed() if it was stuck in send_bytes(). |
| 167 | if sys.platform == 'win32': |
| 168 | self._writer.close() |
| 169 | |
| 170 | self.close() |
| 171 | self.join_thread() |
| 172 | |
| 173 | def _start_thread(self): |
| 174 | debug('Queue._start_thread()') |
nothing calls this directly
no test coverage detected