(self)
| 158 | self.exception_event.clear() |
| 159 | |
| 160 | def close(self): |
| 161 | for worker in self.workers: |
| 162 | worker.stop() |
| 163 | for worker in self.workers: |
| 164 | if worker != threading.current_thread(): |
| 165 | worker.join() |
| 166 | |
| 167 | |
| 168 | class AsyncTask: |
no test coverage detected