Lines Matching refs:chunksize
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)
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
250 for _ in range(chunksize or 1):