Home | History | Annotate | Download | only in multiprocessing

Lines Matching refs:_pool

158         self._pool = []
172 args=(self._taskqueue, self._quick_put, self._outqueue, self._pool)
188 args=(self._taskqueue, self._inqueue, self._outqueue, self._pool,
199 for i in reversed(range(len(self._pool))):
200 worker = self._pool[i]
206 del self._pool[i]
213 for i in range(self._processes - len(self._pool)):
219 self._pool.append(w)
306 chunksize, extra = divmod(len(iterable), len(self._pool) * 4)
460 for p in self._pool: