def terminate_task():
    singleton_pool.run_each(
        _worker_terminate_task,
        [tuple()] * singleton_pool.n_parallel
    )
dataset/ETHPy150Open rllab/rllab/rllab/sampler/parallel_sampler.py/terminate_task/original