python.MpUtils Namespace Reference

Classes
class	SubProcessIterator

Functions
	chunkify (s, chunksize)
	piter (iterable, eoi=None)

Function Documentation

chunkify()

python.MpUtils.chunkify	(		s,
			chunksize )

Yield sequence s in chunks of size chunksize.

>>> list(chunkify('abcdefg', 2))
['ab', 'cd', 'ef', 'g']

>>> list(chunkify('abcdefg', 99))
['abcdefg']

Definition at line 9 of file MpUtils.py.

def chunkify(s, chunksize):
 
    """
    Yield sequence s in chunks of size chunksize.
 
    >>> list(chunkify('abcdefg', 2))
    ['ab', 'cd', 'ef', 'g']
 
    >>> list(chunkify('abcdefg', 99))
    ['abcdefg']
 
    """
 
    for i in range(0, len(s), chunksize):
        yield s[i:i+chunksize]
 

piter()

python.MpUtils.piter	(		iterable,
			eoi = None )

Create a new subprocess iterator.

iterable : some iterable task to execute in a subprocess
eoi : an end-of-iteration marker - returned from the subprocess
      to signal that iteration is complete.

Definition at line 69 of file MpUtils.py.

def piter(iterable, eoi=None):
    """Create a new subprocess iterator.
 
    iterable : some iterable task to execute in a subprocess
    eoi : an end-of-iteration marker - returned from the subprocess
          to signal that iteration is complete.
    """
    return SubProcessIterator(iterable, eoi=eoi)