Server
Оптимизируйте свои подборки
Сохраняйте и классифицируйте контент в соответствии со своими настройками.
Внутренний сервер 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();
}
Публичные конструкторы
| Сервер (byte[] serverDef) Создает новый экземпляр сервера. |
Публичные методы
синхронизированная пустота | закрывать () Уничтожить сервер TensorFlow в процессе, освободить память. |
пустота | присоединиться () Блокируется до тех пор, пока сервер не будет успешно остановлен. |
синхронизированная пустота | начинать () Запускает работающий сервер TensorFlow. |
синхронизированная пустота | |
Унаследованные методы
Из класса java.lang.Object логическое значение | равно (Объект arg0) |
последний класс<?> | получитьКласс () |
интервал | хэш-код () |
окончательная пустота | уведомить () |
окончательная пустота | уведомитьВсе () |
Нить | toString () |
окончательная пустота | подождать (длинный arg0, int arg1) |
окончательная пустота | подождите (длинный arg0) |
окончательная пустота | ждать () |
Из интерфейса java.lang.AutoCloseable абстрактная пустота | закрывать () |
Публичные конструкторы
общедоступный сервер (byte[] serverDef)
Создает новый экземпляр сервера.
Параметры
serverDef | Определение сервера, указанное как сериализованный буфер протокола ServerDef . |
---|
Публичные методы
общедоступная синхронизированная недействительная закрытие ()
Уничтожить сервер TensorFlow в процессе, освободить память.
публичное недействительное присоединение ()
Блокируется до тех пор, пока сервер не будет успешно остановлен.
общедоступный синхронизированный недействительный старт ()
Запускает работающий сервер TensorFlow.
общедоступная синхронизированная недействительная остановка ()
Останавливает работающий сервер TensorFlow.
Если не указано иное, контент на этой странице предоставляется по лицензии Creative Commons "С указанием авторства 4.0", а примеры кода – по лицензии Apache 2.0. Подробнее об этом написано в правилах сайта Google Developers. Java – это зарегистрированный товарный знак корпорации Oracle и/или ее аффилированных лиц. Определенный контент лицензирован по лицензии numpy.
Последнее обновление: 2025-07-28 UTC.
[null,null,["Последнее обновление: 2025-07-28 UTC."],[],[],null,["# Server\n\npublic final class **Server** \nAn in-process TensorFlow server, for use in distributed training.\n\nA `Server` instance encapsulates a set of devices and a [Session](/versions/r2.9/api_docs/java/org/tensorflow/Session)\ntarget that can participate in distributed training. A server belongs to a cluster (specified by\na `ClusterSpec`), and corresponds to a particular task in a named job. The server can\ncommunicate with any other server in the same cluster. The server will not serve any requests\nuntil [start()](/versions/r2.9/api_docs/java/org/tensorflow/Server#start()) is invoked. The server will stop serving requests once [stop()](/versions/r2.9/api_docs/java/org/tensorflow/Server#stop()) or\n[close()](/versions/r2.9/api_docs/java/org/tensorflow/Server#close()) is invoked. Be aware that [close()](/versions/r2.9/api_docs/java/org/tensorflow/Server#close()) method stops the server if it is\nrunning.\n\n**WARNING:** A `Server` owns resources that **must** be explicitly freed by\ninvoking [close()](/versions/r2.9/api_docs/java/org/tensorflow/Server#close()).\n\nInstances of a `Server` are thread-safe.\n\nUsing example:\n\n import org.tensorflow.Server;\n import org.tensorflow.distruntime.ClusterDef;\n import org.tensorflow.distruntime.JobDef;\n import org.tensorflow.distruntime.ServerDef;\n\n ClusterDef clusterDef = ClusterDef.newBuilder()\n .addJob(JobDef.newBuilder()\n .setName(\"worker\")\n .putTasks(0, \"localhost:4321\")\n .build()\n ).build();\n\n ServerDef serverDef = ServerDef.newBuilder()\n .setCluster(clusterDef)\n .setJobName(\"worker\")\n .setTaskIndex(0)\n .setProtocol(\"grpc\")\n .build();\n\n try (Server srv = new Server(serverDef.toByteArray())) {\n srv.start();\n srv.join();\n }\n \n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\n\u003cbr /\u003e\n\n### Public Constructors\n\n|---|--------------------------------------------------------------------------------------------------------------------------------------|\n| | [Server](/versions/r2.9/api_docs/java/org/tensorflow/Server#Server(byte[]))(byte\\[\\] serverDef) Constructs a new instance of server. |\n\n### Public Methods\n\n|-------------------|------------------------------------------------------------------------------------------------------------------------------|\n| synchronized void | [close](/versions/r2.9/api_docs/java/org/tensorflow/Server#close())() Destroy an in-process TensorFlow server, frees memory. |\n| void | [join](/versions/r2.9/api_docs/java/org/tensorflow/Server#join())() Blocks until the server has been successfully stopped. |\n| synchronized void | [start](/versions/r2.9/api_docs/java/org/tensorflow/Server#start())() Starts an in-process TensorFlow server. |\n| synchronized void | [stop](/versions/r2.9/api_docs/java/org/tensorflow/Server#stop())() Stops an in-process TensorFlow server. |\n\n### Inherited Methods\n\nFrom class java.lang.Object \n\n|------------------|---------------------------|\n| boolean | equals(Object arg0) |\n| final Class\\\u003c?\\\u003e | getClass() |\n| int | hashCode() |\n| final void | notify() |\n| final void | notifyAll() |\n| String | toString() |\n| final void | wait(long arg0, int arg1) |\n| final void | wait(long arg0) |\n| final void | wait() |\n\nFrom interface java.lang.AutoCloseable \n\n|---------------|---------|\n| abstract void | close() |\n\nPublic Constructors\n-------------------\n\n#### public\n**Server**\n(byte\\[\\] serverDef)\n\nConstructs a new instance of server. \n\n##### Parameters\n\n| serverDef | Server definition specified as a serialized [ServerDef](https://github.com/tensorflow/tensorflow/blob/master/tensorflow/core/protobuf/tensorflow_server.proto) protocol buffer. |\n|-----------|---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|\n\nPublic Methods\n--------------\n\n#### public synchronized void\n**close**\n()\n\nDestroy an in-process TensorFlow server, frees memory. \n\n##### Throws\n\n| InterruptedException | |\n|----------------------|---|\n\n#### public void\n**join**\n()\n\nBlocks until the server has been successfully stopped. \n\n#### public synchronized void\n**start**\n()\n\nStarts an in-process TensorFlow server. \n\n#### public synchronized void\n**stop**\n()\n\nStops an in-process TensorFlow server."]]