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