(Latest Version)

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.