Lines Matching refs:chunksize
248 def map(self, func, iterable, chunksize=None): argument
253 return self.map_async(func, iterable, chunksize).get()
255 def imap(self, func, iterable, chunksize=1): argument
260 if chunksize == 1:
266 assert chunksize > 1
267 task_batches = Pool._get_tasks(func, iterable, chunksize)
273 def imap_unordered(self, func, iterable, chunksize=1): argument
278 if chunksize == 1:
284 assert chunksize > 1
285 task_batches = Pool._get_tasks(func, iterable, chunksize)
300 def map_async(self, func, iterable, chunksize=None, callback=None): argument
308 if chunksize is None:
309 chunksize, extra = divmod(len(iterable), len(self._pool) * 4)
311 chunksize += 1
313 chunksize = 0
315 task_batches = Pool._get_tasks(func, iterable, chunksize)
316 result = MapResult(self._cache, chunksize, len(iterable), callback)
594 def __init__(self, cache, chunksize, length, callback): argument
598 self._chunksize = chunksize
599 if chunksize <= 0:
604 self._number_left = length//chunksize + bool(length % chunksize)