שרת 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)) {
srv.start();
srv.join();
}
בונים ציבוריים
שיטות ציבוריות
שיטות בירושה
בוליאני | שווה (Object arg0) |
כיתה אחרונה<?> | getClass () |
int | hashcode () |
ריק סופי | להודיע () |
ריק סופי | הודע הכל () |
חוּט | toString () |
ריק סופי | המתן (ארג0 ארוך, אינט arg1) |
ריק סופי | המתן (ארג0 ארוך) |
ריק סופי | חכה () |
ריק מופשט | סגור () |
בונים ציבוריים
שיטות ציבוריות
סגירת ריק מסונכרן ציבורי ()
הרס שרת TensorFlow בתהליך, מפנה זיכרון.
זורק
InterruptedException |
---|
הצטרפות בטל ציבורית ()
חסימה עד שהשרת הופסק בהצלחה.
התחלת ריק מסונכרנת ציבורית ()
מפעיל שרת TensorFlow בתהליך.
עצירת ריק מסונכרנת ציבורית ()
עוצר שרת TensorFlow בתהליך.