ray.util.queue.Queue.put#

Queue.put(item: Any, block: bool = True, timeout: float | None = None) None[源代码]#

向队列中添加一个项目。

如果 block 为 True 且队列已满,则阻塞直到队列不再满或直到超时。

如果多个生产者向同一个满队列中放入数据,顺序无法保证。

抛出:
  • Full – 如果队列已满且阻塞为 False。

  • Full – 如果队列已满,阻塞为 True,并且超时。

  • ValueError – 如果超时为负值。