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

Exception raised when the queue is closed