TF 2.0 is out! Get hands-on practice at TF World, Oct 28-31. Use code TF20 for 20% off select passes. Register now

tf.keras.utils.OrderedEnqueuer

TensorFlow 1 version View source on GitHub

Class OrderedEnqueuer

Builds a Enqueuer from a Sequence.

Inherits From: SequenceEnqueuer

Aliases:

Used in fit_generator, evaluate_generator, predict_generator.

Arguments:

  • sequence: A tf.keras.utils.data_utils.Sequence object.
  • use_multiprocessing: use multiprocessing if True, otherwise threading
  • shuffle: whether to shuffle the data at the beginning of each epoch

__init__

View source

__init__(
    sequence,
    use_multiprocessing=False,
    shuffle=False
)

Initialize self. See help(type(self)) for accurate signature.

Methods

get

View source

get()

Creates a generator to extract data from the queue.

Skip the data if it is None.

Yields:

The next element in the queue, i.e. a tuple (inputs, targets) or (inputs, targets, sample_weights).

is_running

View source

is_running()

start

View source

start(
    workers=1,
    max_queue_size=10
)

Starts the handler's workers.

Arguments:

  • workers: Number of workers.
  • max_queue_size: queue size (when full, workers could block on put())

stop

View source

stop(timeout=None)

Stops running threads and wait for them to exit, if necessary.

Should be called by the same thread which called start().

Arguments:

  • timeout: maximum time to wait on thread.join()