pool

Contents

`pool`#

class fkat.utils.pool.FutureResult(fut: Future[T])[source]#

An AsyncResult implementation for concurrent.future Future object

get(timeout: Optional[float] = None) → T[source]#

ready() → bool[source]#

successful() → bool[source]#

wait(timeout: Optional[float] = None) → None[source]#

class fkat.utils.pool.NoDaemonContext[source]#

A multiprocessing Context that uses NoDaemonProcess

Process#: alias of NoDaemonProcess

class fkat.utils.pool.NoDaemonPool(*args: Any, **kwargs: Any)[source]#: A multiprocessing Pool that uses NoDaemonContext

class fkat.utils.pool.NoDaemonProcess(group=None, target=None, name=None, args=(), kwargs={}, *, daemon=None)[source]#

A Process implementation that never runs in daemon mode

property daemon: bool#: Return whether process is a daemon

class fkat.utils.pool.ThreadPool(**kwargs: Any)[source]#

A multiprocessing Pool-like implementation that uses ThreadPoolExecutor

apply_async(func: Callable[[...], T_co], args: Optional[Iterable[Any]] = None, kwds: Optional[Mapping[str, Any]] = None) → FutureResult[T_co][source]#

close() → None[source]#

join() → None[source]#