HomeSort by relevance Sort by last modified time
    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