morpheus.utils.producer_consumer_queue

Classes

AsyncIOProducerConsumerQueue([maxsize])	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

Exception raised when the queue is closed