tf.queue.PaddingFIFOQueue

Очередь FIFO, поддерживающая пакетную обработку тензоров переменного размера путем дополнения.

Наследует: QueueBase

tf.queue.PaddingFIFOQueue(
    capacity,
    dtypes,
    shapes,
    names=None,
    shared_name=None,
    name='padding_fifo_queue'
)

Объект PaddingFIFOQueue может содержать компоненты с динамической формой и одновременно поддерживать dequeue_many. Подробнее см. описание конструктора.

Описание методов этого класса см. в разделе tf.queue.QueueBase.

Методы

close

Посмотреть исходный код

close(
    cancel_pending_enqueues=False, name=None
)

Закрывает эту очередь.

Эта операция сигнализирует, что в указанную очередь больше нельзя добавлять элементы. Последующие операции enqueue и enqueue_many завершатся ошибкой. Последующие операции dequeue и dequeue_many продолжат выполняться успешно, если в очереди останется достаточно элементов. После этого операции dequeue и dequeue_many, которые в противном случае блокировались бы в ожидании новых элементов (если бы очередь не была закрыта), немедленно завершатся ошибкой.

Если cancel_pending_enqueues равно True, все ожидающие запросы также будут отменены.

dequeue

Посмотреть исходный код

dequeue(
    name=None
)

Извлекает из этой очереди один элемент.

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

Во время выполнения эта операция может вызвать ошибку, если очередь tf.QueueBase.close до начала или в ходе ее выполнения. Если очередь закрыта и пуста, а ожидающих операций добавления, способных выполнить этот запрос, нет, будет вызвано исключение tf.errors.OutOfRangeError. Если сеанс tf.Session.close, будет вызвано исключение tf.errors.CancelledError.

dequeue_many

Посмотреть исходный код

dequeue_many(
    n, name=None
)

Извлекает из этой очереди n элементов и объединяет их.

Эта операция объединяет тензоры-компоненты элементов очереди вдоль измерения 0, создавая один тензор-компонент. Все компоненты в извлеченном кортеже будут иметь размер n по измерению 0.

Если очередь закрыта и в ней осталось меньше n элементов, вызывается исключение OutOfRange.

Во время выполнения эта операция может вызвать ошибку, если очередь tf.QueueBase.close до начала или в ходе ее выполнения. Если очередь закрыта, в ней содержится меньше n элементов, а ожидающих операций добавления, способных выполнить этот запрос, нет, будет вызвано исключение tf.errors.OutOfRangeError. Если сеанс tf.Session.close, будет вызвано исключение tf.errors.CancelledError.

dequeue_up_to

Посмотреть исходный код

dequeue_up_to(
    n, name=None
)

Извлекает из этой очереди n элементов и объединяет их.

Примечание: Эта операция поддерживается не всеми очередями. Если очередь не поддерживает DequeueUpTo, вызывается исключение tf.errors.UnimplementedError.

Эта операция объединяет тензоры-компоненты элементов очереди вдоль измерения 0, создавая один тензор-компонент. Если очередь не закрыта, все компоненты в извлеченном кортеже будут иметь размер n по измерению 0.

Если очередь закрыта и в ней осталось больше 0, но меньше n элементов, то вместо вызова исключения tf.errors.OutOfRangeError, как в случае с tf.QueueBase.dequeue_many, немедленно возвращается меньше n элементов. Если очередь закрыта и в ней осталось 0 элементов, вызывается исключение tf.errors.OutOfRangeError, как и в случае с dequeue_many. В остальных случаях поведение идентично dequeue_many.

enqueue

Посмотреть исходный код

enqueue(
    vals, name=None
)

Добавляет в эту очередь один элемент.

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

Во время выполнения эта операция может вызвать ошибку, если очередь tf.QueueBase.close до начала или в ходе ее выполнения. Если очередь закрыта до запуска этой операции, будет вызвано исключение tf.errors.CancelledError. Если эта операция заблокирована и (i) очередь закрыта операцией close с параметром cancel_pending_enqueues=True или (ii) сеанс tf.Session.close, будет вызвано исключение tf.errors.CancelledError.

enqueue_many

Посмотреть исходный код

enqueue_many(
    vals, name=None
)

Добавляет в эту очередь ноль или более элементов.

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

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

Во время выполнения эта операция может вызвать ошибку, если очередь tf.QueueBase.close до начала или в ходе ее выполнения. Если очередь закрыта до запуска этой операции, будет вызвано исключение tf.errors.CancelledError. Если эта операция заблокирована и (i) очередь закрыта операцией close с параметром cancel_pending_enqueues=True или (ii) сеанс tf.Session.close, будет вызвано исключение tf.errors.CancelledError.

from_list

Посмотреть исходный код

@staticmethod
from_list(
    index, queues
)

Создает очередь, используя ссылку на очередь из queues[index].

is_closed

Посмотреть исходный код

is_closed(
    name=None
)

Возвращает true, если очередь закрыта.

Эта операция возвращает true, если очередь закрыта, и false, если очередь открыта.

size

Посмотреть исходный код

size(
    name=None
)

Вычисляет количество элементов в этой очереди.