Lines Matching refs:func
99 def apply(self, func, args=(), kwds=dict()): argument
102 return self.apply_async(func, args, kwds).get()
104 def map(self, func, iterable, chunksize=None): argument
112 return self.map_async(func, iterable, chunksize).get()
114 def imap(self, func, iterable, chunksize=1): argument
129 self._create_sequences(func, iterable, chunksize, collector)
132 def imap_unordered(self, func, iterable, chunksize=1): argument
138 self._create_sequences(func, iterable, chunksize, collector)
141 def apply_async(self, func, args=(), kwds=dict(), callback=None): argument
152 job = Job(func, args, kwds, apply_result)
156 def map_async(self, func, iterable, chunksize=None, callback=None): argument
167 if not self._create_sequences(func, iterable, chunksize, collector):
171 def imap_async(self, func, iterable, chunksize=None, callback=None): argument
183 if not self._create_sequences(func, iterable, chunksize, collector):
187 def imap_unordered_async(self, func, iterable, chunksize=None, argument
200 if not self._create_sequences(func, iterable, chunksize, collector):
233 def _create_sequences(self, func, iterable, chunksize, collector): argument
257 job = Job(func, (arg,), {}, apply_result)
269 def __init__(self, func, args, kwds, apply_result): argument
275 self._func = func