ray.util.queue.Queue.get_nowait_batch

Queue.get_nowait_batch(num_items: int) → List[Any]

Gets items from the queue and returns them in a list in order.

Parameters:

num_items – Number of items to dequeue.

Returns:

A list of up to num_items items dequeued in FIFO order.

Raises:

Empty – if the queue does not contain the desired number of items