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[source]
Exception raised when the queue is closed