home *** CD-ROM | disk | FTP | other *** search
- # Source Generated with Decompyle++
- # File: in.pyc (Python 2.6)
-
- __docformat__ = 'restructuredtext en'
- from types import FunctionType
- from zope.interface import Interface, implements
-
- class IMultiEngineParallelDecorator(Interface):
-
- def parallel(dist = 'b', targets = None, block = None):
- pass
-
-
-
- class ITaskParallelDecorator(Interface):
-
- def parallel(clear_before = False, clear_after = False, retries = 0, recovery_task = None, depend = None, block = True):
- pass
-
-
-
- class IParallelFunction(Interface):
- pass
-
-
- class ParallelFunction(object):
- implements(IParallelFunction)
-
- def __init__(self, mapper):
- self.mapper = mapper
-
-
- def __call__(self, func):
- self.func = func
-
- def call_function(*sequences):
- return self.mapper.map(self.func, *sequences)
-
- return call_function
-
-
-