lenskit.parallel.pool

Functions

ensure_log_listener()

Classes

ProcessPoolOpInvoker(model, func, n_jobs[, ...])

class lenskit.parallel.pool.ProcessPoolOpInvoker(model, func, n_jobs, progress=None)

Bases: ModelOpInvoker[A, R], Generic[M, A, R]

Parameters:

• model (M)

• func (InvokeOp[M, A, R])

• n_jobs (int)

• progress (Progress)

map(tasks)

Apply the configured function to the model and iterables. This is like map(), except it supplies the invoker’s model as the first object to func.

Parameters:

• iterables – Iterables of arguments to provide to the function.

• tasks (Iterable[A])

Returns:

An iterable of the results.

Return type:

iterable