אזהרה: API זו ברמה נמוכה יוסרה בגרסה עתידית של TensorFlow לאחר ההחלפה יציבה.

Server

כיתת שרת ציבורית

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

בנאים ציבוריים

שרת (בתים [] serverDef)
בונה מופע חדש של שרת.

שיטות ציבוריות

ריק מסונכרן
סגור ()
השמד שרת TensorFlow בתהליך, שחרר זיכרון.
בָּטֵל
הצטרף ()
חסום עד שהשרת נעצר בהצלחה.
ריק מסונכרן
התחל ()
מתחיל שרת TensorFlow בתהליך.
ריק מסונכרן
עצור ()
עוצר שרת TensorFlow בתהליך.

שיטות תורשתיות

בנאים ציבוריים

שרת ציבורי (בתים [] serverDef)

בונה מופע חדש של שרת.

פרמטרים
serverDef הגדרת שרת מוגדרת כמאגר פרוטוקולי ServerDef בסידרה.

שיטות ציבוריות

סנכרון ציבורי ריק סגור ()

השמד שרת TensorFlow בתהליך, שחרר זיכרון.

זורק
חריג מופרע

הצטרף לריק פומבי ()

חסום עד שהשרת נעצר בהצלחה.

התחלה בטלה מסונכרנת ציבורית ()

מתחיל שרת TensorFlow בתהליך.

עצירה בטלנית מסונכרנת בציבור ()

עוצר שרת TensorFlow בתהליך.