Conozca lo último en aprendizaje automático, IA generativa y más en el
Simposio WiML 2023.
Server
Organiza tus páginas con colecciones
Guarda y categoriza el contenido según tus preferencias.
Un servidor TensorFlow en proceso, para usar en capacitación distribuida.
Una instancia de Server
encapsula un conjunto de dispositivos y un objetivo de Session
que puede participar en el entrenamiento distribuido. Un servidor pertenece a un clúster (especificado por un 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 las 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.
Ejemplo de uso:
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 server. |
Métodos públicos
vacío sincronizado | cerrar () Destruye un servidor TensorFlow en proceso, libera memoria. |
vacío | unirse () Bloquea hasta que el servidor se haya detenido correctamente. |
vacío sincronizado | empezar () Inicia un servidor TensorFlow en proceso. |
vacío sincronizado | detener () Detiene un servidor TensorFlow en proceso. |
Métodos Heredados
De la clase java.lang.Object booleano | es igual a (Objeto arg0) |
clase final<?> | obtenerClase () |
En t | código hash () |
vacío final | notificar () |
vacío final | notificar a todos () |
Cuerda | a la cadena () |
vacío final | espera (largo arg0, int arg1) |
vacío final | espera (largo arg0) |
vacío final | espera () |
Desde la interfaz java.lang.AutoCloseable vacío abstracto | cerrar () |
Constructores Públicos
servidor público (byte[] serverDef)
Construye una nueva instancia de server.
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 ()
Destruye un servidor TensorFlow en proceso, libera memoria.
unión de vacío público ()
Bloquea hasta que el servidor se haya detenido correctamente.
inicio vacío sincronizado público ()
Inicia un servidor TensorFlow en proceso.
parada nula sincronizada pública ()
Detiene un servidor TensorFlow en proceso.
Salvo que se indique lo contrario, el contenido de esta página está sujeto a la licencia Atribución 4.0 de Creative Commons, y los ejemplos de código están sujetos a la licencia Apache 2.0. Para obtener más información, consulta las políticas del sitio de Google Developers. Java es una marca registrada de Oracle o sus afiliados. Cierto contenido está sujeto a la licencia de NumPy.
Última actualización: 2023-10-06 (UTC)
[null,null,["Última actualización: 2023-10-06 (UTC)"],[],[],null,["# Server\n\npublic final class **Server** \nAn in-process TensorFlow server, for use in distributed training.\n\nA `Server` instance encapsulates a set of devices and a [Session](/versions/r2.13/api_docs/java/org/tensorflow/Session)\ntarget that can participate in distributed training. A server belongs to a cluster (specified by\na `ClusterSpec`), and corresponds to a particular task in a named job. The server can\ncommunicate with any other server in the same cluster. The server will not serve any requests\nuntil [start()](/versions/r2.13/api_docs/java/org/tensorflow/Server#start()) is invoked. The server will stop serving requests once [stop()](/versions/r2.13/api_docs/java/org/tensorflow/Server#stop()) or\n[close()](/versions/r2.13/api_docs/java/org/tensorflow/Server#close()) is invoked. Be aware that [close()](/versions/r2.13/api_docs/java/org/tensorflow/Server#close()) method stops the server if it is\nrunning.\n\n**WARNING:** A `Server` owns resources that **must** be explicitly freed by\ninvoking [close()](/versions/r2.13/api_docs/java/org/tensorflow/Server#close()).\n\nInstances of a `Server` are thread-safe.\n\nUsing example:\n\n import org.tensorflow.Server;\n import org.tensorflow.distruntime.ClusterDef;\n import org.tensorflow.distruntime.JobDef;\n import org.tensorflow.distruntime.ServerDef;\n\n ClusterDef clusterDef = ClusterDef.newBuilder()\n .addJob(JobDef.newBuilder()\n .setName(\"worker\")\n .putTasks(0, \"localhost:4321\")\n .build()\n ).build();\n\n ServerDef serverDef = ServerDef.newBuilder()\n .setCluster(clusterDef)\n .setJobName(\"worker\")\n .setTaskIndex(0)\n .setProtocol(\"grpc\")\n .build();\n\n try (Server srv = new Server(serverDef.toByteArray())) {\n srv.start();\n srv.join();\n }\n \n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\n### Public Constructors\n\n|---|---------------------------------------------------------------------------------------------------------------------------------------|\n| | [Server](/versions/r2.13/api_docs/java/org/tensorflow/Server#Server(byte[]))(byte\\[\\] serverDef) Constructs a new instance of server. |\n\n### Public Methods\n\n|-------------------|-------------------------------------------------------------------------------------------------------------------------------|\n| synchronized void | [close](/versions/r2.13/api_docs/java/org/tensorflow/Server#close())() Destroy an in-process TensorFlow server, frees memory. |\n| void | [join](/versions/r2.13/api_docs/java/org/tensorflow/Server#join())() Blocks until the server has been successfully stopped. |\n| synchronized void | [start](/versions/r2.13/api_docs/java/org/tensorflow/Server#start())() Starts an in-process TensorFlow server. |\n| synchronized void | [stop](/versions/r2.13/api_docs/java/org/tensorflow/Server#stop())() Stops an in-process TensorFlow server. |\n\n### Inherited Methods\n\nFrom class java.lang.Object \n\n|------------------|---------------------------|\n| boolean | equals(Object arg0) |\n| final Class\\\u003c?\\\u003e | getClass() |\n| int | hashCode() |\n| final void | notify() |\n| final void | notifyAll() |\n| String | toString() |\n| final void | wait(long arg0, int arg1) |\n| final void | wait(long arg0) |\n| final void | wait() |\n\nFrom interface java.lang.AutoCloseable \n\n|---------------|---------|\n| abstract void | close() |\n\nPublic Constructors\n-------------------\n\n#### public\n**Server**\n(byte\\[\\] serverDef)\n\nConstructs a new instance of server. \n\n##### Parameters\n\n| serverDef | Server definition specified as a serialized [ServerDef](https://github.com/tensorflow/tensorflow/blob/master/tensorflow/core/protobuf/tensorflow_server.proto) protocol buffer. |\n|-----------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|\n\nPublic Methods\n--------------\n\n#### public synchronized void\n**close**\n()\n\nDestroy an in-process TensorFlow server, frees memory. \n\n##### Throws\n\n| InterruptedException | |\n|----------------------|---|\n\n#### public void\n**join**\n()\n\nBlocks until the server has been successfully stopped. \n\n#### public synchronized void\n**start**\n()\n\nStarts an in-process TensorFlow server. \n\n#### public synchronized void\n**stop**\n()\n\nStops an in-process TensorFlow server."]]