Быстрое опустошение очереди MPPython

Программы на Python
Anonymous
Быстрое опустошение очереди MP

Сообщение Anonymous »

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

Код: Выделить всё

total_q_item = frames_queue.qsize()
for i in range(total_q_item):
frames_queue.get()
Однако это очень медленно.
Другой вариант, который я нашел в Интернете, — это заменить очередь новым пустым объектом очереди. Однако это не работает, поскольку очередь используется несколькими процессами.
Какие еще есть быстрые варианты?

Подробнее здесь: https://stackoverflow.com/questions/787 ... queue-fast

Вернуться в «Python»