def _get(self, one_shot):
        """ Get a worker queue from the pool. """
        with self._lock:
            try:
                return self._idle.pop()
            except __HOLE__:
                queue = Queue.Queue()
                worker = threading.Thread(target=self._service_loop,
                                          args=(queue, one_shot))
                worker.daemon = True
                worker.start()
                self._workers[queue] = worker
                return queue
dataset/ETHPy150Open OpenMDAO/OpenMDAO-Framework/openmdao.util/src/openmdao/util/wrkpool.py/WorkerPool._get