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, которые в противном случае блокировались бы, ожидая дополнительных элементов (если close не была вызвана), теперь завершатся ошибкой немедленно.

Если 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) очередь закрыта операцией закрытия с cancel_pending_enqueues=True, либо (ii) сессия tf.Session.close, будет выброшено исключение tf.errors.CancelledError.

enqueue_many

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

enqueue_many(
    vals, name=None
)

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

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

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

Во время выполнения данная операция может вызвать ошибку, если очередь 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
)

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