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