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.
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