שרת

שרת TensorFlow בתהליך, לשימוש באימונים מבוזרים.

מופע Server מכיל קבוצה של מכשירים ויעד Session שיכולים להשתתף באימונים מבוזרים. שרת שייך לאשכול (מוגדר על ידי ClusterSpec ), ומתאים למשימה מסוימת בעבודה בשם. השרת יכול לתקשר עם כל שרת אחר באותו אשכול. השרת לא יגיש בקשות כלשהן עדstart() . השרת יפסיק להגיש בקשות לאחר שתופעל stop() אוclose() . שים לב ששיטתclose() עוצרת את השרת אם הוא פועל.

אזהרה: Server מחזיק משאבים כי יש לשחרר במפורש על ידי העלאהclose() .

המופעים של Server הם בטוחים בחוטים.

באמצעות דוגמה:

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();
 
 }