ray.util.queue.Queue.get_async

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

从队列中获取一个项目。

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

返回:

队列中的下一个项目。

抛出:

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

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

• ValueError – 如果超时为负值。