queue – синхронизированный класс очереди¶queue – A synchronized queue class

Объекты очередей¶Queue Objects

Объекты очередей (Queue, LifoQueue или 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)¶

Помещает элемент в очередь. Если необязательный аргумент block истинен и timeout равен None (по умолчанию), блокируется при необходимости до освобождения места. Если timeout – положительное число, блокируется не более чем на timeout секунд и возбуждает исключение Full, если за это время место не освободилось. В противном случае (block ложен), помещает элемент в очередь, если место свободно немедленно, иначе возбуждает исключение Full (в этом случае timeout игнорируется).

Вызывает ShutDown, если очередь была закрыта.

Queue.put_nowait(item)¶

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

Queue.get(block=True, timeout=None)¶

Удаляет элемент из очереди и возвращает его. Если необязательный аргумент block равен true, а timeout равен None (по умолчанию), при необходимости блокирует выполнение, пока элемент не станет доступен. Если timeout – положительное число, блокирует выполнение не более чем на timeout секунд и вызывает исключение Empty, если за это время элемент не появился. В противном случае (block равен false) возвращает элемент, если он доступен немедленно, иначе вызывает исключение Empty (timeout в этом случае игнорируется).

До версии 3.0 в системах POSIX и во всех версиях Windows, если block истинен и timeout равен None, эта операция переходит в непрерываемое ожидание на базовой блокировке. Это означает, что никакие исключения не могут возникнуть, и, в частности, SIGINT не вызовет KeyboardInterrupt.

Возбуждает ShutDown, если очередь была закрыта и пуста, или если очередь была закрыта немедленно.

Queue.get_nowait()¶

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

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

Queue.task_done()¶

Указывает, что ранее поставленная в очередь задача завершена. Используется потоками-потребителями очереди. Для каждого вызова get(), использованного для получения задачи, последующий вызов task_done() сообщает очереди, что обработка задачи завершена.

Если join() в данный момент заблокирован, он возобновит работу, когда все элементы будут обработаны (то есть для каждого элемента, который был put() в очередь, был получен вызов task_done()).

Возбуждает ValueError, если вызывается больше раз, чем было помещено элементов в очередь.

Queue.join()¶

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

Счётчик незавершённых задач увеличивается каждый раз, когда элемент добавляется в очередь. Счётчик уменьшается, когда поток-потребитель вызывает task_done(), чтобы указать, что элемент был получен и вся работа с ним завершена. Когда счетчик незавершённых задач падает до нуля, join() разблокируется.

import threading
import queue

q = queue.Queue()

def worker():
    while True:
        item = q.get()
        print(f'Working on {item}')
        print(f'Finished {item}')
        q.task_done()

# Запустить рабочий поток.
threading.Thread(target=worker, daemon=True).start()

# Отправить рабочему тридцать запросов задач.
for item in range(30):
    q.put(item)

# Ожидать завершения всех задач.
q.join()
print('All work completed')

Объекты SimpleQueue¶SimpleQueue Objects

Объекты SimpleQueue предоставляют описанные ниже публичные методы.

SimpleQueue.qsize()¶

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

SimpleQueue.empty()¶

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

SimpleQueue.put(item, block=True, timeout=None)¶

Помещает элемент в очередь. Метод никогда не блокируется и всегда выполняется успешно (за исключением возможных низкоуровневых ошибок, например, сбоя выделения памяти). Необязательные аргументы block и timeout игнорируются и предоставлены только для совместимости с Queue.put().

Особенность реализации CPython: Этот метод имеет реализацию на C, которая является реентерабельной. То есть вызов put() или get() может быть прерван другим вызовом put() в том же потоке без взаимоблокировки или повреждения внутреннего состояния очереди. Это делает его подходящим для использования в деструкторах, таких как методы __del__ или колбэки weakref.

SimpleQueue.put_nowait(item)¶

Эквивалентно put(item, block=False), предусмотрено для совместимости с Queue.put_nowait().

SimpleQueue.get(block=True, timeout=None)¶

Удаляет элемент из очереди и возвращает его. Если необязательный аргумент block равен true, а timeout равен None (по умолчанию), при необходимости блокирует выполнение, пока элемент не станет доступен. Если timeout – положительное число, блокирует выполнение не более чем на timeout секунд и вызывает исключение Empty, если за это время элемент не появился. В противном случае (block равен false) возвращает элемент, если он доступен немедленно, иначе вызывает исключение Empty (timeout в этом случае игнорируется).

SimpleQueue.get_nowait()¶

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