| /external/python/cpython2/Lib/multiprocessing/ |
| pool.py | 139 self._taskqueue = Queue.Queue()
172 args=(self._taskqueue, self._quick_put, self._outqueue,
189 args=(self._taskqueue, self._inqueue, self._outqueue, self._pool,
260 self._taskqueue.put((((result._job, i, func, (x,), {})
267 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
278 self._taskqueue.put((((result._job, i, func, (x,), {})
285 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
295 self._taskqueue.put(([(result._job, None, func, args, kwds)], None))
315 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
329 pool._taskqueue.put(None
[all...] |
| /external/python/cpython3/Lib/multiprocessing/ |
| pool.py | 151 self._taskqueue = queue.Queue()
181 args=(self._taskqueue, self._quick_put, self._outqueue,
198 args=(self._taskqueue, self._inqueue, self._outqueue, self._pool,
286 self._taskqueue.put((((result._job, i, func, (x,), {})
293 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
305 self._taskqueue.put((((result._job, i, func, (x,), {})
312 self._taskqueue.put((((result._job, i, mapstar, (x,), {})
324 self._taskqueue.put(([(result._job, None, func, args, kwds)], None))
355 self._taskqueue.put((((result._job, i, mapper, (x,), {})
369 pool._taskqueue.put(None
[all...] |
| /prebuilts/gdb/darwin-x86/lib/python2.7/multiprocessing/ |
| pool.py | 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
[all...] |
| /prebuilts/gdb/linux-x86/lib/python2.7/multiprocessing/ |
| pool.py | 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
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
| pool.py | 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
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
| pool.py | 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
[all...] |
