שרת 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 בתהליך.