Lines Matching refs:chunksize
359 def map(self, func, iterable, chunksize=None): argument
364 return self._map_async(func, iterable, mapstar, chunksize).get()
366 def starmap(self, func, iterable, chunksize=None): argument
372 return self._map_async(func, iterable, starmapstar, chunksize).get()
374 def starmap_async(self, func, iterable, chunksize=None, callback=None, argument
379 return self._map_async(func, iterable, starmapstar, chunksize,
393 def imap(self, func, iterable, chunksize=1): argument
398 if chunksize == 1:
407 if chunksize < 1:
410 chunksize))
411 task_batches = Pool._get_tasks(func, iterable, chunksize)
422 def imap_unordered(self, func, iterable, chunksize=1): argument
427 if chunksize == 1:
436 if chunksize < 1:
438 "Chunksize must be 1+, not {0!r}".format(chunksize))
439 task_batches = Pool._get_tasks(func, iterable, chunksize)
460 def map_async(self, func, iterable, chunksize=None, callback=None, argument
465 return self._map_async(func, iterable, mapstar, chunksize, callback,
468 def _map_async(self, func, iterable, mapper, chunksize=None, callback=None, argument
477 if chunksize is None:
478 chunksize, extra = divmod(len(iterable), len(self._pool) * 4)
480 chunksize += 1
482 chunksize = 0
484 task_batches = Pool._get_tasks(func, iterable, chunksize)
485 result = MapResult(self, chunksize, len(iterable), callback,
793 def __init__(self, pool, chunksize, length, callback, error_callback): argument
798 self._chunksize = chunksize
799 if chunksize <= 0:
804 self._number_left = length//chunksize + bool(length % chunksize)