thunderboltz.parallel.DistributedPool

class thunderboltz.parallel.DistributedPool(runner: MPRunner, processes=None)[source]

A multiprocessing Pool context for running calculations among cores with different settings.

Parameters:

  • runner (MPRunner) – The calculation runner.

  • processes (int) – The number of cores to divide up the work.

Methods

err_callback(err)

Print out errors that subprocesses encounter.

submit([run_args])

Submit a single job with updated key words to the pool.