Lines Matching refs:iterable
263 def map(self, func, iterable, chunksize=None): argument
268 return self._map_async(func, iterable, mapstar, chunksize).get()
270 def starmap(self, func, iterable, chunksize=None): argument
276 return self._map_async(func, iterable, starmapstar, chunksize).get()
278 def starmap_async(self, func, iterable, chunksize=None, callback=None, argument
283 return self._map_async(func, iterable, starmapstar, chunksize,
286 def _guarded_task_generation(self, result_job, func, iterable): argument
292 for i, x in enumerate(iterable):
297 def imap(self, func, iterable, chunksize=1): argument
307 self._guarded_task_generation(result._job, func, iterable),
316 task_batches = Pool._get_tasks(func, iterable, chunksize)
327 def imap_unordered(self, func, iterable, chunksize=1): argument
337 self._guarded_task_generation(result._job, func, iterable),
345 task_batches = Pool._get_tasks(func, iterable, chunksize)
367 def map_async(self, func, iterable, chunksize=None, callback=None, argument
372 return self._map_async(func, iterable, mapstar, chunksize, callback,
375 def _map_async(self, func, iterable, mapper, chunksize=None, callback=None, argument
382 if not hasattr(iterable, '__len__'):
383 iterable = list(iterable)
386 chunksize, extra = divmod(len(iterable), len(self._pool) * 4)
389 if len(iterable) == 0:
392 task_batches = Pool._get_tasks(func, iterable, chunksize)
393 result = MapResult(self._cache, chunksize, len(iterable), callback,