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
| 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 () |
| vide abstrait | fermer () |
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.
Jetés
| Exception interrompue |
|---|
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.