เซิร์ฟเวอร์ 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 ในกระบวนการ |
วิธีการสืบทอด
นักก่อสร้างสาธารณะ
เซิร์ฟเวอร์ สาธารณะ (byte [] serverDef)
สร้างอินสแตนซ์ใหม่ของเซิร์ฟเวอร์
พารามิเตอร์
serverDef | นิยามเซิร์ฟเวอร์ที่ระบุเป็นบัฟเฟอร์โปรโตคอล ServerDef แบบ อนุกรม |
---|
วิธีการสาธารณะ
โมฆะซิงโครไนซ์สาธารณะ ปิด ()
ทำลายเซิร์ฟเวอร์ TensorFlow ในกระบวนการทำให้หน่วยความจำว่าง
พ่น
InterruptedException |
---|
โมฆะสาธารณะ join ()
บล็อกจนกว่าเซิร์ฟเวอร์จะหยุดทำงานได้สำเร็จ
โมฆะซิงโครไนซ์สาธารณะ เริ่มต้น ()
เริ่มต้นเซิร์ฟเวอร์ TensorFlow ในกระบวนการ
โมฆะที่ซิงโครไนซ์สาธารณะ หยุด ()
หยุดเซิร์ฟเวอร์ TensorFlow ในกระบวนการ