tf.keras.utils.OrderedEnqueuer
| Просмотреть исходный код на GitHub |
Создаёт Enqueuer из Sequence.
Наследуется от: SequenceEnqueuer
tf.keras.utils.OrderedEnqueuer(
sequence, use_multiprocessing=False, shuffle=False
)
| Аргументы | |
|---|---|
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() |
© 2022 The TensorFlow Authors. All rights reserved.
Licensed under the Creative Commons Attribution License 4.0.
Code samples licensed under the Apache 2.0 License.
https://www.tensorflow.org/versions/r2.9/api_docs/python/tf/keras/utils/OrderedEnqueuer
