run_trainer.py 文件源码

def run_enqueue_server(episodes):
  grpc_server = grpc.server(futures.ThreadPoolExecutor(max_workers=3))
  model_pb2.add_ModelServicer_to_server(EnqueueServer(episodes), grpc_server)
  grpc_server.add_insecure_port("[::]:%d" % opts.trainer_port)
  grpc_server.start()
  while True:
    time.sleep(10)