Lines Matching refs:_taskqueue
139 self._taskqueue = Queue.Queue()
172 args=(self._taskqueue, self._quick_put, self._outqueue, self._pool)
188 args=(self._taskqueue, self._inqueue, self._outqueue, self._pool,
259 self._taskqueue.put((((result._job, i, func, (x,), {})
266 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
277 self._taskqueue.put((((result._job, i, func, (x,), {})
284 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
294 self._taskqueue.put(([(result._job, None, func, args, kwds)], None))
314 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
328 pool._taskqueue.put(None)
