> **Источник:** https://python-all.ru/2.7/library/queue.html
>
> «Документация Python на русском» – неофициальный перевод официальной документации Python: версии от 2.6 до 3.16, полнотекстовый поиск, английский оригинал рядом с переводом. Эта Markdown-версия страницы предназначена для работы с LLM: вставьте её в ChatGPT, Claude или Cursor.

---

# 8.10. [`Queue`](https://python-all.ru/2.7/library/queue.html#module-Queue) – синхронизированный класс очереди

> **Примечание**
>
> Модуль [`Queue`](https://python-all.ru/2.7/library/queue.html#module-Queue) был переименован в `queue` в Python 3. Инструмент [2to3](https://python-all.ru/2.7/glossary.html#term-2to3) автоматически адаптирует импорты при преобразовании исходных кодов в Python 3.

**Исходный код:** [Lib/Queue.py](https://python-all.ru/src/2.7/Lib/Queue.py)

---

Модуль [`Queue`](https://python-all.ru/2.7/library/queue.html#module-Queue) реализует очереди с несколькими производителями и потребителями. Он особенно полезен в многопоточном программировании, когда необходимо безопасно обмениваться данными между несколькими потоками. Класс [`Queue`](https://python-all.ru/2.7/library/queue.html#Queue.Queue) в этом модуле реализует всю необходимую семантику блокировок. Он зависит от наличия поддержки потоков в Python; см. модуль [`threading`](https://python-all.ru/2.7/library/threading.html#module-threading).

Модуль реализует три типа очередей, которые различаются только порядком, в котором элементы извлекаются. В очереди FIFO первые добавленные задачи извлекаются первыми. В очереди LIFO последний добавленный элемент извлекается первым (работает как стек). В очереди с приоритетом элементы хранятся отсортированными (с использованием модуля [`heapq`](https://python-all.ru/2.7/library/heapq.html#module-heapq)), и элемент с наименьшим значением извлекается первым.

Модуль [`Queue`](https://python-all.ru/2.7/library/queue.html#module-Queue) определяет следующие классы и исключения:

#### `class Queue.Queue(maxsize=0)`

Конструктор очереди FIFO. *maxsize* – целое число, которое задает верхнюю границу количества элементов, которые можно поместить в очередь. Вставка будет блокироваться, как только этот размер достигнут, пока элементы очереди не будут потреблены. Если *maxsize* меньше или равно нулю, размер очереди бесконечен.

#### `class Queue.LifoQueue(maxsize=0)`

Конструктор очереди LIFO. *maxsize* – целое число, которое задает верхнюю границу количества элементов, которые можно поместить в очередь. Вставка будет блокироваться, как только этот размер достигнут, пока элементы очереди не будут потреблены. Если *maxsize* меньше или равно нулю, размер очереди бесконечен.

Новое в версии 2.6.

#### `class Queue.PriorityQueue(maxsize=0)`

Конструктор для очереди с приоритетом. *maxsize* – целое число, задающее верхний предел количества элементов, которые можно поместить в очередь. Вставка будет блокироваться, когда этот размер достигнут, пока элементы очереди не будут потреблены. Если *maxsize* меньше или равно нулю, размер очереди бесконечен.

Элементы с наименьшим значением извлекаются первыми (элемент с наименьшим значением – это тот, который возвращается `sorted(list(entries))[0]`). Типичный шаблон для элементов – кортеж вида: `(priority_number, data)`.

Новое в версии 2.6.

#### `exception Queue.Empty`

Исключение, возбуждаемое при вызове неблокирующего [`get()`](https://python-all.ru/2.7/library/queue.html#Queue.Queue.get) (или [`get_nowait()`](https://python-all.ru/2.7/library/queue.html#Queue.Queue.get_nowait)) на пустом объекте [`Queue`](https://python-all.ru/2.7/library/queue.html#Queue.Queue).

#### `exception Queue.Full`

Исключение, возбуждаемое при вызове неблокирующего [`put()`](https://python-all.ru/2.7/library/queue.html#Queue.Queue.put) (или [`put_nowait()`](https://python-all.ru/2.7/library/queue.html#Queue.Queue.put_nowait)) на полном объекте [`Queue`](https://python-all.ru/2.7/library/queue.html#Queue.Queue).

> **См. также**
>
> [`collections.deque`](https://python-all.ru/2.7/library/collections.html#collections.deque) – альтернативная реализация неограниченных очередей с быстрыми атомарными операциями `append()` и `popleft()`, не требующими блокировки.

## 8.10.1. Объекты очереди

Объекты очередей ([`Queue`](https://python-all.ru/2.7/library/queue.html#Queue.Queue), [`LifoQueue`](https://python-all.ru/2.7/library/queue.html#Queue.LifoQueue) или [`PriorityQueue`](https://python-all.ru/2.7/library/queue.html#Queue.PriorityQueue)) предоставляют описанные ниже открытые методы.

#### `Queue.qsize()`

Возвращает приблизительный размер очереди. Обратите внимание: qsize() \> 0 не гарантирует, что последующий вызов get() не заблокируется, равно как qsize() \< maxsize не гарантирует, что put() не заблокируется.

#### `Queue.empty()`

Возвращает `True`, если очередь пуста, и `False` в противном случае. Если empty() возвращает `True`, это не гарантирует, что последующий вызов put() не заблокируется. Аналогично, если empty() возвращает `False`, это не гарантирует, что последующий вызов get() не заблокируется.

#### `Queue.full()`

Возвращает `True`, если очередь заполнена, и `False` в противном случае. Если full() возвращает `True`, это не гарантирует, что последующий вызов get() не заблокируется. Аналогично, если full() возвращает `False`, это не гарантирует, что последующий вызов put() не заблокируется.

#### `Queue.put(item[, block[, timeout]])`

Помещает *item* в очередь. Если необязательный аргумент *block* равен true, а *timeout* равен `None` (по умолчанию), блокирует при необходимости до появления свободного места. Если *timeout* – положительное число, блокирует не более *timeout* секунд и вызывает исключение [`Full`](https://python-all.ru/2.7/library/queue.html#Queue.Full), если за это время свободное место не появилось. В противном случае (*block* равен false), помещает элемент в очередь, если свободное место доступно немедленно, иначе вызывает исключение [`Full`](https://python-all.ru/2.7/library/queue.html#Queue.Full) (*timeout* в этом случае игнорируется).

Новое в версии 2.3: Параметр *timeout*.

#### `Queue.put_nowait(item)`

Эквивалентно `put(item, False)`.

#### `Queue.get([block[, timeout]])`

Удаляет и возвращает элемент из очереди. Если необязательный аргумент *block* равен true, а *timeout* равен `None` (по умолчанию), блокирует при необходимости до появления элемента. Если *timeout* – положительное число, блокирует не более *timeout* секунд и вызывает исключение [`Empty`](https://python-all.ru/2.7/library/queue.html#Queue.Empty), если за это время элемент не появился. В противном случае (*block* равен false), возвращает элемент, если он доступен немедленно, иначе вызывает исключение [`Empty`](https://python-all.ru/2.7/library/queue.html#Queue.Empty) (*timeout* в этом случае игнорируется).

Новое в версии 2.3: Параметр *timeout*.

#### `Queue.get_nowait()`

Эквивалентно `get(False)`.

Предлагаются два метода для отслеживания того, были ли задачи, поставленные в очередь, полностью обработаны потоками-потребителями-демонами.

#### `Queue.task_done()`

Указывает, что ранее поставленная в очередь задача завершена. Используется потоками-потребителями очереди. Для каждого вызова [`get()`](https://python-all.ru/2.7/library/queue.html#Queue.Queue.get), использованного для получения задачи, последующий вызов [`task_done()`](https://python-all.ru/2.7/library/queue.html#Queue.Queue.task_done) сообщает очереди, что обработка задачи завершена.

Если [`join()`](https://python-all.ru/2.7/library/queue.html#Queue.Queue.join) в данный момент заблокирован, он возобновит работу, когда все элементы будут обработаны (то есть для каждого элемента, который был [`put()`](https://python-all.ru/2.7/library/queue.html#Queue.Queue.put) в очередь, был получен вызов [`task_done()`](https://python-all.ru/2.7/library/queue.html#Queue.Queue.task_done)).

Возбуждает [`ValueError`](https://python-all.ru/2.7/library/exceptions.html#exceptions.ValueError), если вызывается больше раз, чем было помещено элементов в очередь.

Новое в версии 2.5.

#### `Queue.join()`

Блокируется до тех пор, пока все элементы в очереди не будут получены и обработаны.

Счётчик незавершённых задач увеличивается при добавлении элемента в очередь. Счётчик уменьшается, когда поток-потребитель вызывает [`task_done()`](https://python-all.ru/2.7/library/queue.html#Queue.Queue.task_done), указывая, что элемент получен и вся работа над ним завершена. Когда счётчик незавершённых задач падает до нуля, [`join()`](https://python-all.ru/2.7/library/queue.html#Queue.Queue.join) разблокируется.

Новое в версии 2.5.

Пример ожидания завершения поставленных в очередь задач:

```python
def worker():
    while True:
        item = q.get()
        do_work(item)
        q.task_done()

q = Queue()
for i in range(num_worker_threads):
     t = Thread(target=worker)
     t.daemon = True
     t.start()

for item in source():
    q.put(item)

q.join()       # ожидать завершения всех задач
```