tf.contrib.training.FeedingQueueRunner

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

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

tf.contrib.training.FeedingQueueRunner(
    queue=None, enqueue_ops=None, close_op=None, cancel_op=None, feed_fns=None,
    queue_closed_exception_types=None
)

Аргументы
`queue`	`Queue`.
`enqueue_ops`	Список операций добавления в очередь для выполнения в потоках позже.
`close_op`	Операция закрытия очереди. Необработанные операции добавления в очередь сохраняются.
`cancel_op`	Операция закрытия очереди и отмены необработанных операций добавления в очередь.
`feed_fns`	Список функций, возвращающих словарь, отображающий подаваемые `Tensor` в значения. Длина должна быть такой же, как у `enqueue_ops`.
`queue_closed_exception_types`	Необязательная кортеж типов исключений, указывающих, что очередь закрыта, когда они возникают во время операции добавления в очередь. По умолчанию `(tf.errors.OutOfRangeError, tf.errors.CancelledError)`.

Исключения
`ValueError`	`feed_fns` не является `None` и имеет другую длину, чем `enqueue_ops`.

Атрибуты
`cancel_op`
`close_op`
`enqueue_ops`
`exceptions_raised`	Исключения, которые возникают, но не обрабатываются потоками `QueueRunner`. Исключения, возникающие в потоках очереди выполнения, обрабатываются одним из двух способов в зависимости от того, передавался ли `Coordinator` в `create_threads()`. С `Coordinator`, исключения сообщаются координатору и забываются потоками `QueueRunner`. Без `Coordinator`, исключения перехватываются `QueueRunner` и доступны в этом свойстве `exceptions_raised`.
`name`	Имя строки базовой очереди.
`queue`
`queue_closed_exception_types`

Методы

`create_threads`

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

create_threads(
    sess, coord=None, daemon=False, start=False
)

Создает потоки для выполнения операций добавления в очередь для данной сессии.

Этот метод требует сессии, в которой была запущена графика. Он создает список потоков, необязательно запуская их. Один поток создается для каждой операции, переданной в enqueue_ops.

Аргумент coord — это необязательный координатор, который потоки будут использовать для одновременной остановки и отчёта об исключениях. Если координатор указан, этот метод запускает дополнительный поток для закрытия очереди, когда координатор запросит остановку.

Если ранее созданные потоки для данной сессии всё ещё работают, новые потоки создаваться не будут.

Аргументы
`sess`	`Session`.
`coord`	Необязательный объект координатора для отслеживания ошибок и проверки условий остановки.
`daemon`	Булево. Если `True`, сделать потоки демоническими.
`start`	Булево. Если `True`, запустить потоки. Если `False`, вызывающий должен вызвать метод `start()` возвращённых потоков.

Возвращаемое значение
Список потоков.

`from_proto`

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

@staticmethod
from_proto(
    queue_runner_def, import_scope=None
)

Возвращает объект QueueRunner созданный из queue_runner_def.

`to_proto`

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

to_proto()

Преобразует этот объект QueueRunner в протокол буфера QueueRunnerDef.

Аргументы
`export_scope`	Необязательный `string`. Название области видимости для удаления.

Возвращаемое значение
Протокол буфера `QueueRunnerDef`, или `None`, если `Variable` не находится в заданной области видимости.

© 2020 The TensorFlow Authors. All rights reserved.
Licensed under the Creative Commons Attribution License 3.0.
Code samples licensed under the Apache 2.0 License.
https://www.tensorflow.org/versions/r1.15/api_docs/python/tf/contrib/training/FeedingQueueRunner