← Сtrl

Андрей Светлов · Янв. 27, 2011 17:46:33

Зачем в workere? Вызывайте в главном потоке, прямо в обработчике сигнала.
Да, размер меняется и это нехорошо. Итерируйтесь по копии.

Игнат · Янв. 29, 2011 15:54:22

если сделать копию:

            cp = set()
            cp |= self.pending
            for f in cp:
                f.cancel()

не работает:

  File "/usr/local/lib/python3.2/concurrent/futures/_base.py", line 391, in result
    raise CancelledError()
concurrent.futures._base.CancelledError

если итерировать по копии - я не знаю как получить элемент из self.pending
это множество set() и питон говорит что к нему нельзя обращаться по индексу

а если изменить тип self.pending на list, то валятся ошибки:

AttributeError: 'list' object has no attribute 'add'
AttributeError: 'list' object has no attribute 'discard'

как же тогда итерироваться по копии?

Андрей Светлов · Янв. 29, 2011 17:50:29

for f in set(self.pending):
    if not f.cancelled():
        f.cancel()

Как-то так.

Игнат · Фев. 2, 2011 08:12:06

отлично! теперь работает как надо и без ошибок :)
огромное спасибо!

Отредактировано (Фев. 2, 2011 08:12:23)

Python-сообщество

Уведомления

#1 Янв. 27, 2011 17:46:33

как прервать работу потоков в concurrent.futures?

#2 Янв. 29, 2011 15:54:22

как прервать работу потоков в concurrent.futures?

#3 Янв. 29, 2011 17:50:29

как прервать работу потоков в concurrent.futures?

#4 Фев. 2, 2011 08:12:06

как прервать работу потоков в concurrent.futures?

Board footer