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

---

# `queue` – синхронизированный класс очереди

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

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

Модуль `очередь` определяет следующие классы и исключения:

#### `[queue.Queue]class queue.Queue(maxsize)`

Конструктор очереди FIFO.

*maxsize*

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

*maxsize*

меньше или равно нулю, размер очереди бесконечен.

#### `[queue.LifoQueue]class queue.LifoQueue(maxsize)`

Конструктор очереди LIFO.

*maxsize*

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

*maxsize*

меньше или равно нулю, размер очереди бесконечен.

#### `[queue.PriorityQueue]class queue.PriorityQueue(maxsize)`

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

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

#### `[queue.Empty]exception queue.Empty`

Исключение возникает при вызове неблокирующего

`get()`

(или

`get_nowait()`

) для пустого объекта

[`очереди`](https://python-all.ru/3.0/library/queue.html#queue.Queue)

.

#### `[queue.Full]exception queue.Full`

Исключение возникает при вызове неблокирующего

`put()`

(или

`put_nowait()`

) для полного объекта

[`очереди`](https://python-all.ru/3.0/library/queue.html#queue.Queue)

.

## Объекты очередей

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

#### `[queue.Queue.qsize]Queue.qsize()`

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

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

Помещает

*item*

в очередь. Если необязательный аргумент

*block*

равен true, а

*timeout*

равен None (значение по умолчанию), при необходимости блокируется до появления свободного места. Если

*timeout*

– положительное число, блокируется не более чем на

*timeout*

секунд и возбуждает исключение

[`Full`](https://python-all.ru/3.0/library/queue.html#queue.Full)

, если свободное место не появилось за это время. В противном случае (

*block*

равен false) помещает элемент в очередь, если свободное место есть немедленно; иначе возбуждает исключение

[`Full`](https://python-all.ru/3.0/library/queue.html#queue.Full)

(в этом случае

*timeout*

игнорируется).

#### `[queue.Queue.put_nowait]Queue.put_nowait(item)`

Эквивалентно

`put(item, False)`

.

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

Удаляет и возвращает элемент из очереди. Если необязательный аргумент

*block*

равен true и

*timeout*

равен None (по умолчанию), при необходимости блокируется до появления элемента. Если

*timeout*

– положительное число, он блокируется не более чем на

*timeout*

секунд и возбуждает исключение

[`Empty`](https://python-all.ru/3.0/library/queue.html#queue.Empty)

, если за это время элемент не появился. В противном случае (

*block*

равен false) возвращает элемент, если он доступен немедленно; иначе возбуждает исключение

[`Empty`](https://python-all.ru/3.0/library/queue.html#queue.Empty)

(в этом случае

*timeout*

игнорируется).

#### `[queue.Queue.get_nowait]Queue.get_nowait()`

Эквивалентно

`get(False)`

.

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

#### `[queue.Queue.task_done]Queue.task_done()`

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

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

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

#### `[queue.Queue.join]Queue.join()`

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

Счётчик незавершённых задач увеличивается всякий раз, когда элемент добавляется в очередь. Счётчик уменьшается, когда поток-потребитель вызывает [`task_done()`](https://python-all.ru/3.0/library/queue.html#queue.Queue.task_done), чтобы сообщить, что элемент был извлечён и вся работа над ним завершена. Когда счётчик незавершённых задач падает до нуля, 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.set_daemon(True)
     t.start()

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

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