storage_continous_parallel_image.py 文件源码

def __init__(self, args, task_q, result_q, actor_id, monitor):
        multiprocessing.Process.__init__(self)
        self.actor_id = actor_id
        self.task_q = task_q
        self.result_q = result_q
        self.args = args
        self.monitor = monitor
        # pms.max_path_length = gym.spec(args.environment_name).timestep_limit