alphatwirl.concurrently.SubprocessRunner

class alphatwirl.concurrently.SubprocessRunner(pipe=False)[source]

An example dispatcher which runs tasks in subprocesses

This class is an example of a dispatcher.

Note: This class is not for practical use as it doesn’t limit the number of subprocesses running concurrently.

__init__(pipe=False)[source]

Initialize self. See help(type(self)) for accurate signature.

Methods

__init__([pipe]) Initialize self.
failed_runids(runids)
poll() check if the jobs are running and return a list of pids for finished jobs
run(workingArea, package_index)
run_multiple(workingArea, package_indices)
terminate()
wait() wait until all jobs finish and return a list of pids