(self)
| 347 | self.shutdown() |
| 348 | |
| 349 | def spawn_worker(self): |
| 350 | if self._max_workers and len(self._workers) >= self._max_workers: |
| 351 | return |
| 352 | |
| 353 | t = click_threading.Thread(target=self._worker) |
| 354 | t.start() |
| 355 | self._workers.append(t) |
| 356 | |
| 357 | @contextlib.contextmanager |
| 358 | def join(self): |
no outgoing calls
no test coverage detected