pythonwrench.concurrent module¶

class pythonwrench.concurrent.ThreadPoolExecutorHelper(fn: Callable[[P], T], *, executor_kwds: dict[str, Any] | None = None, executor: ThreadPoolExecutor | None = None, futures: Iterable[Future[T]] = (), **default_fn_kwds)[source]¶

Bases: Generic[P, T]

submit(*args: __SPHINX_IMMATERIAL_TYPE_VAR__P_P, **kwargs: __SPHINX_IMMATERIAL_TYPE_VAR__P_P) → Future[T][source]¶

wait_all(shutdown: bool = True, verbose: bool = True) → list[T][source]¶