Server
Restez organisé à l'aide des collections
Enregistrez et classez les contenus selon vos préférences.
Un serveur TensorFlow en cours, à utiliser dans la formation distribuée.
Une instance Server
encapsule un ensemble d'appareils et une cible Session
qui peuvent participer à une formation distribuée. Un serveur appartient à un cluster (spécifié par un ClusterSpec
) et correspond à une tâche particulière dans un travail nommé. Le serveur peut communiquer avec n'importe quel autre serveur du même cluster. Le serveur ne répondra à aucune requête tant que start()
ne sera pas invoqué. Le serveur cessera de répondre aux requêtes une fois que stop()
ou close()
sera invoqué. Sachez que la méthode close()
arrête le serveur s'il est en cours d'exécution.
AVERTISSEMENT : un Server
possède des ressources qui doivent être explicitement libérées en appelant close()
.
Les instances d'un Server
sont thread-safe.
Exemple d'utilisation :
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();
}
Constructeurs Publics
| Serveur (octet[] serverDef) Construit une nouvelle instance de serveur. |
Méthodes publiques
vide synchronisé | fermer () Détruisez un serveur TensorFlow en cours, libère de la mémoire. |
vide | rejoindre () Bloque jusqu'à ce que le serveur ait été arrêté avec succès. |
vide synchronisé | commencer () Démarre un serveur TensorFlow en cours. |
vide synchronisé | arrêt () Arrête un serveur TensorFlow en cours. |
Méthodes héritées
De la classe java.lang.Object booléen | est égal à (Objet arg0) |
Classe finale<?> | obtenirClasse () |
int | Code de hachage () |
vide final | notifier () |
vide final | notifierTous () |
Chaîne | àChaîne () |
vide final | attendre (long arg0, int arg1) |
vide final | attendez (long arg0) |
vide final | attendez () |
Depuis l'interface java.lang.AutoCloseable Constructeurs Publics
serveur public (octet[] serverDef)
Construit une nouvelle instance de serveur.
Paramètres
serveurDef | Définition du serveur spécifiée en tant que tampon de protocole ServerDef sérialisé. |
---|
Méthodes publiques
fermeture publique synchronisée du vide ()
Détruisez un serveur TensorFlow en cours, libère de la mémoire.
jointure publique vide ()
Bloque jusqu'à ce que le serveur ait été arrêté avec succès.
démarrage vide synchronisé public ()
Démarre un serveur TensorFlow en cours.
arrêt d'annulation public synchronisé ()
Arrête un serveur TensorFlow en cours.
Sauf indication contraire, le contenu de cette page est régi par une licence Creative Commons Attribution 4.0, et les échantillons de code sont régis par une licence Apache 2.0. Pour en savoir plus, consultez les Règles du site Google Developers. Java est une marque déposée d'Oracle et/ou de ses sociétés affiliées. Une partie du contenu fait l'objet d'une licence Numpy.
Dernière mise à jour le 2025/07/27 (UTC).
[null,null,["Dernière mise à jour le 2025/07/27 (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."]]