パブリック最終クラスサーバー
分散トレーニングで使用するためのインプロセス 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 サーバーを停止します。 |
継承されたメソッド
パブリックコンストラクター
パブリックメソッド
public synchronized void close ()
インプロセス TensorFlow サーバーを破棄し、メモリを解放します。
投げる
中断された例外 |
---|
public void join ()
サーバーが正常に停止されるまでブロックします。
public synchronized void start ()
インプロセス TensorFlow サーバーを開始します。
public synchronized void stop ()
インプロセス TensorFlow サーバーを停止します。