Server
Mantieni tutto organizzato con le raccolte
Salva e classifica i contenuti in base alle tue preferenze.
Un server TensorFlow in-process, da utilizzare nella formazione distribuita.
Un'istanza Server
incapsula un set di dispositivi e una destinazione Session
che può partecipare alla formazione distribuita. Un server appartiene a un cluster (specificato da ClusterSpec
) e corrisponde a una particolare attività in un lavoro denominato. Il server può comunicare con qualsiasi altro server nello stesso cluster. Il server non servirà alcuna richiesta finché non verrà richiamato start()
. Il server smetterà di servire le richieste una volta richiamato stop()
o close()
. Tieni presente che il metodo close()
arresta il server se è in esecuzione.
ATTENZIONE: un Server
possiede risorse che devono essere liberate esplicitamente invocando close()
.
Le istanze di un Server
sono thread-safe.
Utilizzando l'esempio:
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();
}
Costruttori pubblici
| Server (byte[] serverDef) Costruisce una nuova istanza del server. |
Metodi pubblici
vuoto sincronizzato | vicino () Distrugge un server TensorFlow in-process e libera memoria. |
vuoto | giuntura () Si blocca finché il server non viene arrestato con successo. |
vuoto sincronizzato | inizio () Avvia un server TensorFlow in-process. |
vuoto sincronizzato | fermata () Arresta un server TensorFlow in corso. |
Metodi ereditati
Dalla classe java.lang.Object booleano | è uguale a (Oggetto arg0) |
Classe finale<?> | getClass () |
int | codicehash () |
vuoto finale | avvisare () |
vuoto finale | notificaTutti () |
Corda | aStringa () |
vuoto finale | attendere (lungo arg0, int arg1) |
vuoto finale | aspetta (lungo arg0) |
vuoto finale | Aspettare () |
Dall'interfaccia java.lang.AutoCloseable Costruttori pubblici
Server pubblico (byte[] serverDef)
Costruisce una nuova istanza del server.
Parametri
serverDef | Definizione del server specificata come buffer del protocollo ServerDef serializzato. |
---|
Metodi pubblici
vuoto sincronizzato pubblico chiudi ()
Distrugge un server TensorFlow in-process e libera memoria.
public void join ()
Si blocca finché il server non viene arrestato con successo.
inizio vuoto sincronizzato pubblico ()
Avvia un server TensorFlow in-process.
arresto del vuoto pubblico sincronizzato ()
Arresta un server TensorFlow in corso.
Salvo quando diversamente specificato, i contenuti di questa pagina sono concessi in base alla licenza Creative Commons Attribution 4.0, mentre gli esempi di codice sono concessi in base alla licenza Apache 2.0. Per ulteriori dettagli, consulta le norme del sito di Google Developers. Java è un marchio registrato di Oracle e/o delle sue consociate. Alcuni contenuti sono concessi in base alla licenza NumPy.
Ultimo aggiornamento 2025-07-28 UTC.
[null,null,["Ultimo aggiornamento 2025-07-28 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.9/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.9/api_docs/java/org/tensorflow/Server#start()) is invoked. The server will stop serving requests once [stop()](/versions/r2.9/api_docs/java/org/tensorflow/Server#stop()) or\n[close()](/versions/r2.9/api_docs/java/org/tensorflow/Server#close()) is invoked. Be aware that [close()](/versions/r2.9/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.9/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.9/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.9/api_docs/java/org/tensorflow/Server#close())() Destroy an in-process TensorFlow server, frees memory. |\n| void | [join](/versions/r2.9/api_docs/java/org/tensorflow/Server#join())() Blocks until the server has been successfully stopped. |\n| synchronized void | [start](/versions/r2.9/api_docs/java/org/tensorflow/Server#start())() Starts an in-process TensorFlow server. |\n| synchronized void | [stop](/versions/r2.9/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."]]