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

---

# 17.7. [`queue`](https://python-all.ru/3.4/library/queue.html#module-queue) – Синхронизированная очередь

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

---

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

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

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

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

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

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

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

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

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

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

#### `exception queue.Empty`

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

#### `exception queue.Full`

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

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

Объекты очереди ([`Queue`](https://python-all.ru/3.4/library/queue.html#queue.Queue), [`LifoQueue`](https://python-all.ru/3.4/library/queue.html#queue.LifoQueue) или [`PriorityQueue`](https://python-all.ru/3.4/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=True, timeout=None)`

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

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

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

#### `Queue.get(block=True, timeout=None)`

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

#### `Queue.get_nowait()`

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

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

#### `Queue.task_done()`

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

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

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

#### `Queue.join()`

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

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

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

```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()       # ожидать завершения всех задач
```

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