morpheus.utils.producer_consumer_queue
NVIDIA Docs Hub  NVIDIA Morpheus  morpheus.utils.producer_consumer_queue

Classes

AsyncIOProducerConsumerQueue([maxsize, loop])

Custom queue.Queue implementation which supports closing and uses recursive locks

ProducerConsumerQueue([maxsize])

Custom queue.Queue implementation which supports closing and uses recursive locks

Exceptions

Closed

Exception raised when the queue is closed
exception Closed[source]

Exception raised when the queue is closed
© Copyright 2023, NVIDIA. Last updated on Apr 11, 2023.