Как остановить поток Thread?

Question

[Гектор Синхром]

Функция вызывает поток (индикатор выполнения этой функции). Как мне остановить поток по завершению работы этой функции.

def main_func():
    thread_indicator = threading.Thread(target=indicator_edit)
    thread_indicator.start()
    time.sleep(5) # do something
    # thread.kill()

Comments

[Дмитрий Шицков]

Интересно вот... А зачем маркировать работу функции потоком?

[Гектор Синхром]

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

[Дмитрий Шицков]

Гектор Синхром, стоит сделать наоборот. В основном потоке дать знать пользователю что идёт фонова обработка, запустить тред с этой обработкой и выполнить join в основном потоке. Так основной поток дождётся завершения треда.

[Гектор Синхром]

Дмитрий Шицков, но я всёравно не понимаю как это сделать. Приведу пример. Я тут бота пишу для телеги, который аудио конвертирует и хочу чтобы он, когда начиналась конвертация отправлял сообщение и редактировал его, чтобы получалось "Идёт конвертация . " -> "Идёт конвертация . . " -> "Идёт конвертация . . ." -> "Идёт конвертация . " А когда конвертация заканчивалась - удалял это сообщение.

# вот основной поток в котором происходит обработка
def sounndcloud_downdload (url, user_id):
    #тут происходит проверка существования ссылки, если он есть - то идём дальше, если нет - то ошибка
    sc_api = SoundcloudAPI(client_id='0BkysEEs4PncmjybpuEn3MHCx8nEnDUc')
    track = sc_api.resolve(url)

    # в этом моменте мне нужно запустить индикатор
    sent_message = bot.send_message(user_id, 'Идёт конвертация . ') #вот отправка сообщения
    status = True
    thread_indicator = threading.Thread(target=indicator_edit, args=(sent_message.message_id, user_id, status))
    thread_indicator.start()

    # тут начинается сама обработка
    assert type(track) is Track
    filename = f'./{track.artist} - {track.title}.mp3'
    with open(filename, 'wb+') as fp:
        track.write_mp3_to(fp)

    # это последняя часть, отправка файла
    send_audio(filename, user_id)
    <i># thread.kill() здесь мне нужно остановить мой индикатор</i>

# вот сам индикатор. Тут идёт изменение сообщения. 
# Я не знаю как мне остановить этот цикл while в тот момент, когда обработка основной функцией # завершиться.
def indicator_edit (message_id, user_id, status, stop_event):
    while status:
        for i in range(1, 4):
            text = f'Идёт конвертация ' + '. ' * i
            bot.edit_message_text(chat_id=user_id, message_id=message_id, text=text)

Answer 1

[Дмитрий Шицков]

Нативного решения этой задачи нет. Находил такой удобный пример.

class StoppableThread(threading.Thread):
    """Thread class with a stop() method. The thread itself has to check
    regularly for the stopped() condition."""

    def __init__(self,  *args, **kwargs):
        super(StoppableThread, self).__init__(*args, **kwargs)
        self._stop_event = threading.Event()

    def stop(self):
        self._stop_event.set()

    def stopped(self):
        return self._stop_event.is_set()

Тогда у вашего потока будет метод stop(), который можно вызвать. Но сама функция, работающая в этом потоке, должна регулярно проверять значение stopped() и выходить как только значение стало True.

Функция вызывающая stop() должна выполнить join(), чтобы убедиться в том, что Thread точно завершил свое выполнение.