Skip to content

TaskExecutor.md

Latest commit

 

History

History
29 lines (20 loc) · 2.99 KB

TaskExecutor.md

File metadata and controls

29 lines (20 loc) · 2.99 KB
Raw

Описание класса TaskExecutor

TaskExecutor представляет собой исполнитель задач, который обрабатывает запросы к сервису MLP.

Поля класса TaskExecutor

  • action: Объект, реализующий интерфейс MlpService, который выполняет основную логику обработки запросов.
  • config: Конфигурация сервиса MLP, используемая для настройки исполнителя задач.
  • context: Контекст выполнения, включающий информацию о среде исполнения.

Методы класса TaskExecutor

  • predict(request: PredictRequestProto, requestId: Long, connectorId: Long, tracker: TimeTracker): Обрабатывает запрос на предсказание.
  • fit(request: FitRequestProto, requestId: Long, connectorId: Long): Обрабатывает запрос на обучение модели.
  • ext(request: ExtendedRequestProto, requestId: Long, connectorId: Long): Обрабатывает расширенный запрос.
  • batch(request: BatchRequestProto, requestId: Long, connectorId: Long): Обрабатывает пакетный запрос.
  • initContainer(connectorId: Long): Включает обработку новых задач для коннектора с указанным идентификатором (в том числе после остановки, инициированной гейтом).
  • disableNewJobs(connectorId: Long): Закрывает приём новых задач коннектора, не трогая выполняющиеся (первый шаг остановки).
  • streamOpened / streamTouched / streamFinished(connectorId: Long, requestId: Long): Учёт открытых стримов, которые сервис досылает сам после MlpPartialBinaryResponse; проброс в JobsContainer.
  • cancelAll(): Отменяет все активные задачи.
  • cancelAll(connectorId: Long): Отменяет все задачи конкретного коннектора.
  • gracefulShutdownAll(connectorId: Long, deadline: Instant = now() + actionConnectorMs, abortEarly: () -> Boolean = { false }): Дожидается активных задач коннектора до общего дедлайна остановки и отменяет то, что не успело; abortEarly прекращает ожидание, когда канал уже закрыт гейтом.

Вспомогательные методы класса TaskExecutor

  • launchAndStore(requestId: Long, connectorId: Long, block: suspend () -> Unit): Запускает задачу и сохраняет ее в контейнере задач.
  • toString(): Возвращает строковое представление объекта.