alphatwirl.concurrently.SubprocessRunner

class alphatwirl.concurrently.SubprocessRunner(pipe=False)

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)

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