Модуль queue реализует очереди с несколькими производителями и несколькими потребителями. Это особенно полезно в потоковом программировании, когда информация должна безопасно обмениваться между несколькими потоками. Класс queue.Queue в этом модуле реализует всю необходимую семантику блокировки.
Класс Queue() модуля queue представляет собой конструктор для синхронизированной очереди FIFO. Аргумент maxsize - это целое число, которое устанавливает верхний предел для количества элементов очереди.
Класс LifoQueue() модуля queue представляет собой конструктор для синхронизированной очереди LIFO - стек (первым пришел - последним вышел). Аргумент maxsize - это целое число, которое устанавливает максимально количество элементов в очереди.
Функция PriorityQueue() модуля queue представляет собой конструктор для синхронизированной очереди с приоритетом. Записи с наименьшим значением извлекаются первыми. Типичным шаблоном для записей является кортеж в форме: (priority_number, data).
Создаются в момент инициализации классов queue.Queue(), queue.LifoQueue() или queue.PriorityQueue() и имеют методы для получения размера очереди, проверки если очередь пуста или заполнена, добавление и получение элемента из очереди. Методы отслеживания того, были ли поставленные в обработаны.
Пример иллюстрирует ситуацию когда нужно распараллелить обработку элементов списка, при этом получить результат в котором положение элементов будут соответствовать изначальному т.е. элементы позиционно не перемешаются.
Класс SimpleQueue() модуля queue представляет собой конструктор для неограниченной очереди FIFO. В очереди отсутствует расширенная функциональность, такая как отслеживание задач.
Модуль синхронизированной очереди queue определяет два исключения: queue.Empty и queue.Full.