tf.keras.utils.OrderedEnqueuer

Создаёт Enqueuer из Sequence.

Наследуется от: SequenceEnqueuer

Псевдонимы совместимости для миграции

См. Руководство по миграции для получения дополнительной информации.

tf.keras.utils.OrderedEnqueuer(
    sequence, use_multiprocessing=False, shuffle=False
)

Используется в fit_generator, evaluate_generator, predict_generator.

Аргументы
`sequence`	Объект `tf.keras.utils.data_utils.Sequence`.
`use_multiprocessing`	Использовать многопроцессорность, если True, иначе многопоточность.
`shuffle`	Перемешивать данные в начале каждой эпохи.

Методы

get()

Создаёт генератор для извлечения данных из очереди.

Пропускает данные, если они None.

Возвращаемые значения
Следующий элемент в очереди, т.е. кортеж `(inputs, targets)` или `(inputs, targets, sample_weights)`.

is_running()

start(
    workers=1, max_queue_size=10
)

Запускает рабочие процессы обработчика.

Аргументы
`workers`	Количество рабочих процессов.
`max_queue_size`	Размер очереди (при переполнении рабочие процессы могут заблокироваться на `put()`).

stop(
    timeout=None
)

Останавливает работающие потоки и ждёт их завершения, если необходимо.

Должен вызываться тем же потоком, который вызвал start().

Аргументы
`timeout`	Максимальное время ожидания `thread.join()`

© 2020 The TensorFlow Authors. All rights reserved.
Licensed under the Creative Commons Attribution License 3.0.
Code samples licensed under the Apache 2.0 License.
https://www.tensorflow.org/versions/r2.4/api_docs/python/tf/keras/utils/OrderedEnqueuer