tf.queue.RandomShuffleQueue

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

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

tf.queue.RandomShuffleQueue(
    capacity,
    min_after_dequeue,
    dtypes,
    shapes=None,
    names=None,
    seed=None,
    shared_name=None,
    name='random_shuffle_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 до или во время её выполнения. Если очередь закрыта, она пуста, и нет ожидающих операций 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) очередь закрыта операцией закрытия с 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
)

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