OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:inqueue
(Results
1 - 2
of
2
) sorted by null
/prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/
pool.py
88
def worker(
inqueue
, outqueue, initializer=None, initargs=(), maxtasks=None):
91
get =
inqueue
.get
92
if hasattr(
inqueue
, '_writer'):
93
inqueue
._writer.close()
464
def _help_stuff_finish(
inqueue
, task_handler, size):
465
# task_handler may be blocked trying to put items on
inqueue
466
debug('removing tasks from
inqueue
until task handler finished')
467
inqueue
._rlock.acquire()
468
while task_handler.is_alive() and
inqueue
._reader.poll():
469
inqueue
._reader.recv(
[
all
...]
/prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/
pool.py
88
def worker(
inqueue
, outqueue, initializer=None, initargs=(), maxtasks=None):
91
get =
inqueue
.get
92
if hasattr(
inqueue
, '_writer'):
93
inqueue
._writer.close()
464
def _help_stuff_finish(
inqueue
, task_handler, size):
465
# task_handler may be blocked trying to put items on
inqueue
466
debug('removing tasks from
inqueue
until task handler finished')
467
inqueue
._rlock.acquire()
468
while task_handler.is_alive() and
inqueue
._reader.poll():
469
inqueue
._reader.recv(
[
all
...]
Completed in 26 milliseconds