caf.toolkit.concurrency.multiprocessing_wrapper#

Library of multiprocessing functionality.

Functions

create_kill_pool_fn(pool, ...)

Create a Callback function for each function in a Pool.

multiprocess(fn, *[, arg_list, kwarg_list, ...])

Run a function and arguments across multiple cores of a CPU.

wait_for_pool_results(results, ...[, ...])

Wait for and grab results from a multiprocessing Pool.

Classes

Any(*args, **kwargs)

Special type indicating an unconstrained type.

TypeVar(name, *constraints[, bound, ...])

Type variable.