sphinx.util.parallel.ParallelTasks

class documentation

class ParallelTasks:

View In Hierarchy

Executes nproc tasks in parallel after forking.
Method __init__ Undocumented
Method ​_join​_one Undocumented
Method ​_process Undocumented
Method add​_task Undocumented
Method join Undocumented
Method terminate Undocumented
Instance Variable ​_args Undocumented
Instance Variable ​_precvs Undocumented
Instance Variable _precvs​Waiting Undocumented
Instance Variable ​_procs Undocumented
Instance Variable ​_pworking Undocumented
Instance Variable ​_result​_funcs Undocumented
Instance Variable ​_taskid Undocumented
Instance Variable nproc Undocumented
def __init__(self, nproc):

Undocumented

Parameters
nproc:intUndocumented
def _join_one(self):

Undocumented

Returns
boolUndocumented
def _process(self, pipe, func, arg):

Undocumented

Parameters
pipe:AnyUndocumented
func:CallableUndocumented
arg:AnyUndocumented
def add_task(self, task_func, arg=None, result_func=None):

Undocumented

Parameters
task​_func:CallableUndocumented
arg:AnyUndocumented
result​_func:CallableUndocumented
def join(self):

Undocumented

def terminate(self):

Undocumented

_args: Dict[int, Optional[List[Any]]] =

Undocumented

_precvs: Dict[int, Any] =

Undocumented

_precvsWaiting: Dict[int, Any] =

Undocumented

_procs: Dict[int, multiprocessing.context.ForkProcess] =

Undocumented

_pworking: int =

Undocumented

_result_funcs: Dict[int, Callable] =

Undocumented

_taskid: int =

Undocumented

nproc =

Undocumented