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
| 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 () |
| vuoto astratto | vicino () |
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.
Lancia
| InterruptedException |
|---|
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.