Un servidor TensorFlow en proceso, para uso en capacitación distribuida.
Una instancia Server
encapsula un conjunto de dispositivos y un objetivo Session
que pueden participar en la capacitación distribuida. Un servidor pertenece a un clúster (especificado por ClusterSpec
) y corresponde a una tarea particular en un trabajo con nombre. El servidor puede comunicarse con cualquier otro servidor en el mismo clúster. El servidor no atenderá ninguna solicitud hasta que se invoque start()
. El servidor dejará de atender solicitudes una vez que se invoque stop()
o close()
. Tenga en cuenta que el método close()
detiene el servidor si se está ejecutando.
ADVERTENCIA: Un Server
posee recursos que deben liberarse explícitamente invocando close()
.
Las instancias de un Server
son seguras para subprocesos.
Usando el ejemplo:
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();
}
Constructores Públicos
Servidor (byte[] serverDef) Construye una nueva instancia de servidor. |
Métodos públicos
vacío sincronizado | cerca () Destruir un servidor TensorFlow en proceso, libera memoria. |
vacío | unirse () Bloquea hasta que el servidor se haya detenido exitosamente. |
vacío sincronizado | comenzar () Inicia un servidor TensorFlow en proceso. |
vacío sincronizado | detener () Detiene un servidor TensorFlow en proceso. |
Métodos heredados
Constructores Públicos
Servidor público (byte[] serverDef)
Construye una nueva instancia de servidor.
Parámetros
servidorDef | Definición de servidor especificada como un búfer de protocolo ServerDef serializado. |
---|
Métodos públicos
cierre de vacío sincronizado público ()
Destruir un servidor TensorFlow en proceso, libera memoria.
Lanza
Excepción interrumpida |
---|
unión pública vacía ()
Bloquea hasta que el servidor se haya detenido exitosamente.
inicio vacío sincronizado público ()
Inicia un servidor TensorFlow en proceso.
parada vacía sincronizada pública ()
Detiene un servidor TensorFlow en proceso.