tf.queue.PaddingFIFOQueue

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

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

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

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

См. tf.queue.QueueBase для описания методов данного класса.

Методы

close

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

close(
    cancel_pending_enqueues=False, name=None
)

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

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

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

dequeue

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

dequeue(
    name=None
)

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

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

Во время выполнения эта операция может вызвать ошибку, если очередь tf.QueueBase.close до или во время ее выполнения. Если очередь закрыта, очередь пуста, и нет ожидающих операций enqueue, которые могут удовлетворить этому запросу, будет выброшено исключение 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 элементов, и нет ожидающих операций enqueue, которые могут выполнить этот запрос, будет выброшено исключение 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) очередь закрыта операцией закрытия с 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
)

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