python очередь, когда возникает исключение перед task_done - PullRequest
1 голос
/ 14 февраля 2020

Сценарий:

# readQ is a queue
# threaded_func is used via python threading
def threaded_func(readQ): 
    while True:
    taskval=readQ.get()

    # some unknown error happens here throwing some exception
    # this causes thread to exit at this point
    # this also means readQ.task_done below is never called for that readQ.get
    readQ.task_done()

Итак, если элемент очереди был прочитан, но task_done не вызван, а поток умер, есть ли способ проверить:

  1. элементов в очереди, которые были «извлечены», но не завершены
  2. Сколько времени они были «извлечены» без task_done?
  3. Можно ли отключить такие задачи и поставить их обратно? в «доступном» режиме?
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...