Lines Matching refs:chunksize
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,
297 def imap(self, func, iterable, chunksize=1): argument
303 if chunksize == 1:
312 if chunksize < 1:
315 chunksize))
316 task_batches = Pool._get_tasks(func, iterable, chunksize)
327 def imap_unordered(self, func, iterable, chunksize=1): argument
333 if chunksize == 1:
342 if chunksize < 1:
344 "Chunksize must be 1+, not {0!r}".format(chunksize))
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
385 if chunksize is None:
386 chunksize, extra = divmod(len(iterable), len(self._pool) * 4)
388 chunksize += 1
390 chunksize = 0
392 task_batches = Pool._get_tasks(func, iterable, chunksize)
393 result = MapResult(self._cache, chunksize, len(iterable), callback,
676 def __init__(self, cache, chunksize, length, callback, error_callback): argument
681 self._chunksize = chunksize
682 if chunksize <= 0:
687 self._number_left = length//chunksize + bool(length % chunksize)