

def initialize(n_parallel):
    singleton_pool.initialize(n_parallel)
    singleton_pool.run_each(_worker_init, [(id,) for id in xrange(singleton_pool.n_parallel)])

dataset/ETHPy150Open rllab/rllab/rllab/sampler/parallel_sampler.py initialize/original