Предупреждение: этот API устарел и будет удален в будущей версии TensorFlow после того, как замена станет стабильной.

Server

общедоступный сервер окончательного класса

Внутрипроцессный сервер TensorFlow для использования в распределенном обучении.

Экземпляр Server инкапсулирует набор устройств и цель Session которые могут участвовать в распределенном обучении. Сервер принадлежит к кластеру (указанному ClusterSpec ) и соответствует определенной задаче в названном задании. Сервер может взаимодействовать с любым другим сервером в том же кластере. Сервер не будет обслуживать запросы, пока не будет вызвана функция start() . Сервер перестанет обслуживать запросы после вызова stop() или close() . Имейте в виду, что метод close() останавливает сервер, если он запущен.

ВНИМАНИЕ: Server владеет ресурсами, которые должны быть явно освобождены с помощью вызова close() .

Экземпляры Server являются потокобезопасными.

Пример использования:

import org.tensorflow.Server;
 import org.tensorflow.distruntime.ClusterDef;
 import org.tensorflow.distruntime.JobDef;
 import org.tensorflow.distruntime.ServerDef;

 ClusterDef clusterDef = ClusterDef.newBuilder()
   .addJob(JobDef.newBuilder()
   .setName("worker")
   .putTasks(0, "localhost:4321")
   .build()
 ).build();

 ServerDef serverDef = ServerDef.newBuilder()
   .setCluster(clusterDef)
   .setJobName("worker")
   .setTaskIndex(0)
   .setProtocol("grpc")
 .build();

 try (Server srv = new Server(serverDef.toByteArray())) {
   srv.start();
   srv.join();
 
 }

Общественные конструкторы

Сервер (byte [] serverDef)
Создает новый экземпляр сервера.

Публичные методы

синхронизированная пустота
закрыть ()
Уничтожить внутрипроцессный сервер TensorFlow, освободить память.
пустота
присоединиться ()
Блокирует до тех пор, пока сервер не будет успешно остановлен.
синхронизированная пустота
начало ()
Запускает внутрипроцессный сервер TensorFlow.
синхронизированная пустота
стоп ()
Останавливает внутрипроцессный сервер TensorFlow.

Унаследованные методы

Общественные конструкторы

общедоступный сервер (byte [] serverDef)

Создает новый экземпляр сервера.

Параметры
serverDef Определение сервера указано как сериализованный буфер протокола ServerDef .

Публичные методы

общедоступная синхронизированная пустота close ()

Уничтожить внутрипроцессный сервер TensorFlow, освободить память.

Броски
InterruptedException

public void join ()

Блокирует до тех пор, пока сервер не будет успешно остановлен.

общедоступный синхронизированный void start ()

Запускает внутрипроцессный сервер TensorFlow.

общедоступная синхронизированная пустая остановка ()

Останавливает внутрипроцессный сервер TensorFlow.