server.py 文件源码

def run(self):
        self.stats.start()

        for i in np.arange(FLAGS.nb_concurrent):
            self.agents.append(Agent(i, self.prediction_q, self.training_q, self.stats.episode_log_q))
            self.agents[-1].start()

        for i in np.arange(FLAGS.nb_trainers):
            self.trainers.append(Trainer(self, i))
            self.trainers[-1].start()
        for i in np.arange(FLAGS.nb_predictors):
            self.predictors.append(Predictor(self, i))
            self.predictors[-1].start()


        while True:
            if self.stats.episode_count.value % FLAGS.checkpoint_interval:
                self.save_model()
            time.sleep(0.05)