tf.queue.FIFOQueue

Реализация очереди, которая извлекает элементы в порядке очереди «первым вошел — первым вышел».

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

tf.queue.FIFOQueue(
    capacity, dtypes, shapes=None, names=None, shared_name=None,
    name='fifo_queue'
)

См. 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) очередь закрыта операцией 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
)

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