def get_idle_worker(self):
        try:
            return self.idle_workers.pop()[1]
        except __HOLE__:
            p = multiprocessing.Pool(1, init_env, [self.init_args])
            p.done = 0
            return p
dataset/ETHPy150Open douban/dpark/dpark/executor.py/MyExecutor.get_idle_worker