lenskit.parallel#

LensKit parallel computation support.

Submodules#

`config`
`ray`	Support for parallelism with Ray.

Classes#

An accelerated task, implemented by the accelerator backend.

Functions#

run_accel_task(task, *[, progress])

Run a accelerated backend task with progress, cancellation, etc.

Package Contents#

lenskit.parallel.run_accel_task[R](task, *, progress=None)#

Run a accelerated backend task with progress, cancellation, etc.

Parameters:

task (AccelTask[R])
progress (lenskit.logging.Progress | None)

Return type:

R

Exported Aliases#

lenskit.parallel.effective_cpu_count()#: Re-exported alias for lenskit.parallel.config.effective_cpu_count().

lenskit.parallel.ensure_parallel_init()#: Re-exported alias for lenskit.parallel.config.ensure_parallel_init().

lenskit.parallel.get_parallel_config()#: Re-exported alias for lenskit.parallel.config.get_parallel_config().

lenskit.parallel.init_threading()#: Re-exported alias for lenskit.parallel.config.init_threading().

lenskit.parallel.is_free_threaded()#: Re-exported alias for lenskit.parallel.config.is_free_threaded().