HomeSort by relevance Sort by last modified time
    Searched refs:outqueue (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):
90 put = outqueue.put
94 outqueue._reader.close()
332 def _handle_tasks(taskqueue, put, outqueue, pool):
359 outqueue.put(None)
371 def _handle_results(outqueue, get, cache):
412 if hasattr(outqueue, '_reader'):
413 debug('ensuring that outqueue is not full')
414 # If we don't make room available in outqueue then
415 # attempts to add the sentinel (None) to outqueue ma
    [all...]
  /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/
pool.py 88 def worker(inqueue, outqueue, initializer=None, initargs=(), maxtasks=None):
90 put = outqueue.put
94 outqueue._reader.close()
332 def _handle_tasks(taskqueue, put, outqueue, pool):
359 outqueue.put(None)
371 def _handle_results(outqueue, get, cache):
412 if hasattr(outqueue, '_reader'):
413 debug('ensuring that outqueue is not full')
414 # If we don't make room available in outqueue then
415 # attempts to add the sentinel (None) to outqueue ma
    [all...]

Completed in 35 milliseconds