MultiprocessingJob

despasito.utils.parallelization.MultiprocessingJob

class MultiprocessingJob(ncores=-1)[source]

This object initiates the pool for multiprocessing jobs.

Parameters:: ncores (int, Optional, default=-1) – Number of processes used. If the default value of -1, the system cpu count is used.
Variables:: pool (function) – This pool is used to parallelize jobs.

`MultiprocessingJob.end_pool`()	Close multiprocessing pool
`MultiprocessingJob.pool_job`(func, inputs)	This function will setup and dispatch thermodynamic or parameter fitting jobs.
`MultiprocessingJob.serial_job`(func, inputs)	This function will serially perform thermodynamic jobs.