ray.util.queue.Queue.get

Queue.get(block: bool = True, timeout: float | None = None) → Any

从队列中获取一个项目。

如果 block 为 True 且队列为空，则阻塞直到队列不再为空或直到超时。

如果多个消费者从同一个空队列中获取数据，不保证顺序。

返回:

队列中的下一个项目。

抛出:

• Empty – 如果队列为空且阻塞为 False。

• Empty – 如果队列为空，阻塞为真，并且它超时了。

• ValueError – 如果超时为负值。