(self, timeout: float | None = None)
| 279 | self.ex = sys.exc_info() |
| 280 | |
| 281 | def join(self, timeout: float | None = None) -> None: |
| 282 | super().join(timeout=timeout) |
| 283 | if self.ex is not None: |
| 284 | raise RuntimeError from self.ex[1] # pragma: no cover # only a worker that raised gets re-raised here |
| 285 | |
| 286 | |
| 287 | # 100 threads x 100 acquisitions is thousands of lock cycles; the 20s default is tight on a loaded Windows runner. |
no outgoing calls
no test coverage detected