Parallel iterator built using the fork() system call

class sage.parallel.use_fork.WorkerData(input_value, starttime=None, failure='')[source]

Bases: object

Simple class which stores data about a running p_iter_fork worker.

This just stores three attributes:

  • input – the input value used by this worker

  • starttime – the walltime when this worker started

  • failure – an optional message indicating the kind of failure

EXAMPLES:

sage: from sage.parallel.use_fork import WorkerData
sage: W = WorkerData(42); W
<sage.parallel.use_fork.WorkerData object at ...>
sage: W.starttime  # random
1499330252.463206

>>> from sage.all import *
>>> from sage.parallel.use_fork import WorkerData
>>> W = WorkerData(Integer(42)); W
<sage.parallel.use_fork.WorkerData object at ...>
>>> W.starttime  # random
1499330252.463206
class sage.parallel.use_fork.p_iter_fork(ncpus, timeout=0, verbose=False, reset_interfaces=True)[source]

Bases: object

A parallel iterator implemented using fork().

INPUT:

  • ncpus – the maximal number of simultaneous subprocesses to spawn

  • timeout – float (default: 0); wall time in seconds until a subprocess is automatically killed

  • verbose – boolean (default: False); whether to print anything about what the iterator does (e.g., killing subprocesses)

  • reset_interfaces – boolean (default: True); whether to reset all pexpect interfaces

EXAMPLES:

sage: X = sage.parallel.use_fork.p_iter_fork(2,3, False); X
<sage.parallel.use_fork.p_iter_fork object at ...>
sage: X.ncpus
2
sage: X.timeout
3.0
sage: X.verbose
False

>>> from sage.all import *
>>> X = sage.parallel.use_fork.p_iter_fork(Integer(2),Integer(3), False); X
<sage.parallel.use_fork.p_iter_fork object at ...>
>>> X.ncpus
2
>>> X.timeout
3.0
>>> X.verbose
False