TaskRunner

публичный класс TaskRunner

Бегунок графов задач MediaPipe.

Публичные методы

пустота
закрывать ()
Закрывает и очищает экземпляр TaskRunner .
статический TaskRunner
создать (Контекстный контекст, TaskInfo <? расширяет TaskOptions > TaskInfo, OutputHandler <? расширяет TaskResult , ?> outputHandler)
Создайте экземпляр TaskRunner .
КалькуляторГрафКонфигурация
getCalculatorGraphConfig ()
AndroidPacketCreator
getPacketCreator ()
Возвращает ERROR(/AndroidPacketCreator) связанную с экземпляром TaskRunner .
синхронизированный TaskResult
процесс (входы Map < String , Packet>)
Синхронный метод обработки пакетных данных.
синхронизированный TaskResult
процесс (входы Map < String , Packet>, длинный inputTimestamp)
Синхронный метод обработки данных автономной потоковой передачи.
пустота
перезапуск ()
Сбрасывает и перезапускает экземпляр TaskRunner .
синхронизированная пустота
send (входы Map < String , Packet>, длинный inputTimestamp)
Асинхронный метод обработки потоковых данных в реальном времени.
пустота
setErrorListener (прослушиватель ErrorListener )
Устанавливает обратный вызов, который будет вызываться при возникновении исключений экземпляром TaskRunner .

Унаследованные методы

Публичные методы

public void закрыть ()

Закрывает и очищает экземпляр TaskRunner .

public static TaskRunner create (контекст контекста, TaskInfo <? расширяет TaskOptions > TaskInfo, OutputHandler <? расширяет TaskResult , ?> outputHandler)

Создайте экземпляр TaskRunner .

Параметры
контекст ERROR(/Context) .
задачаИнформация Экземпляр TaskInfo содержит имя графа задачи, параметры задачи и имена входных и выходных потоков графа.
обработчик вывода Экземпляр OutputHandler обрабатывает объект результата задачи и исключение времени выполнения.
Броски
за любую ошибку во время создания TaskRunner .

public CalculatorGraphConfig getCalculatorGraphConfig ()

общедоступный AndroidPacketCreator getPacketCreator ()

Возвращает ERROR(/AndroidPacketCreator) связанную с экземпляром TaskRunner .

общедоступный синхронизированный процесс TaskResult (входные данные Map < String , Packet>)

Синхронный метод обработки пакетных данных.

Примечание. Этот метод предназначен для пакетной обработки данных, таких как несвязанные изображения и тексты. Вызов блокирует текущий поток до тех пор, пока не будет возвращено состояние сбоя или успешный результат. Для каждого вызова будет назначена внутренняя временная метка. Этот метод является потокобезопасным и позволяет клиентам вызывать его из разных потоков.

Параметры
входы карта содержит пары (входной поток String , данные ERROR(/Packet) ).

общедоступный синхронизированный процесс TaskResult (входы Map < String , Packet>, длинный inputTimestamp)

Синхронный метод обработки данных автономной потоковой передачи.

Примечание. Этот метод предназначен для обработки данных автономной потоковой передачи, таких как декодированные кадры из видеофайла и аудиофайла. Вызов блокирует текущий поток до тех пор, пока не будет возвращено состояние сбоя или успешный результат. Вызывающий должен убедиться, что входная временная метка больше, чем временные метки предыдущих вызовов. Этот метод небезопасен для потоков, и вызывающая сторона несет ответственность за синхронизацию доступа к этому методу в нескольких потоках и за обеспечение правильности временных меток входных пакетов.

Параметры
входы карта содержит пары (входной поток String , data ERROR(/Packet) ).
входная метка времени временная метка входных пакетов.

общественный недействительный перезапуск ()

Сбрасывает и перезапускает экземпляр TaskRunner . Это может быть полезно для сброса графа задач с отслеживанием состояния для обработки новых данных.

общедоступная синхронизированная недействительная отправка (входы Map < String , Packet>, длинный inputTimestamp)

Асинхронный метод обработки потоковых данных в реальном времени.

Примечание. Этот метод предназначен для обработки данных потоковой передачи в реальном времени, таких как данные камеры и микрофона в реальном времени. Для получения выходных пакетов в конструкторе должна быть предусмотрена определяемая пользователем функция обратного вызова пакетов. Вызывающая сторона должна гарантировать, что временные метки входных пакетов монотонно увеличиваются. Этот метод небезопасен для потоков, и вызывающая сторона несет ответственность за синхронизацию доступа к этому методу в нескольких потоках и за обеспечение правильности временных меток входных пакетов.

Параметры
входы карта содержит пары (входной поток String , данные ERROR(/Packet) ).
входная метка времени временная метка входных пакетов.

public void setErrorListener (прослушиватель ErrorListener )

Устанавливает обратный вызов, который будет вызываться при возникновении исключений экземпляром TaskRunner .

Параметры
слушатель обратный вызов ErrorListener .