(self)
| 143 | close() |
| 144 | |
| 145 | def join_thread(self): |
| 146 | debug('Queue.join_thread()') |
| 147 | assert self._closed, "Queue {0!r} not closed".format(self) |
| 148 | if self._jointhread: |
| 149 | self._jointhread() |
| 150 | |
| 151 | def cancel_join_thread(self): |
| 152 | debug('Queue.cancel_join_thread()') |