tf.keras.utils.OrderedEnqueuer
| Просмотреть исходный код на GitHub |
Создаёт 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
get()
Создаёт генератор для извлечения данных из очереди.
Пропускает данные, если они None.
Возвращает:
Следующий элемент в очереди, т.е. кортеж (inputs, targets) или (inputs, targets, sample_weights).
is_running
is_running()
start
start(
workers=1, max_queue_size=10
)
Запускает потоки обработчиков.
| Аргументы | |
|---|---|
workers | Количество потоков. |
max_queue_size | Размер очереди (при переполнении потоки могут заблокироваться на put()) |
stop
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.3/api_docs/python/tf/keras/utils/OrderedEnqueuer
