Как прекратить поток в Python?

Question

[EugeneVKruglov]

Здравствуйте! Прошу объяснить мне, как новичку, почему я не могу прекратить выполнение потока и наоборот, запустить поток в питоне приведенным ниже способом? Задача состоит в том, чтобы выполнять некоторые фоновые действия в то время, пока работает основной функционал бота.
Из кода убрал все лишнее, оставил только проблемные части в виде тестовых функций.

import telebot
import time
import datetime
import threading

global stop_thread
stop_thread = False

#---- объявление других переменных, действия и функции

@bot.message_handler(content_types = ['text'])
def get_user_text(message):
    if message.text == '/stop_thread':
        if 'stop_thread' in globals():
            stop_thread = True
            print('Получен запрос на остановку потока')
            print('stop_thread =', stop_thread) 
            # в консоли выводится, что значение стало True, но до потока оно почему-то не доходит, 
            # внутри функции start_thread() остается False
    if message.text == '/start_thread':
        if 'stop_thread' in globals():
            stop_thread = False
        t = threading.Thread(target = start_thread)
        t.start() # запустить поток таким образом тоже не получается

#---- другие действия и функции

def start_thread():
    print(f'Начало отсчета: {datetime.datetime.utcnow()}')
    print('stop_thread =', stop_thread)
    while not stop_thread:
        print('Работает поток... stop_thread =', stop_thread)
        print(f'Прошло 3 секунды, {datetime.datetime.utcnow()}')
        time.sleep(3)

t = threading.Thread(target = start_thread)
t.start()

#---- еще действия и функции

# стартуем бота
bot.polling(non_stop = True)

При запуске по F5 все идет нормально, бот функционирует, параллельно запускается поток, который выводит тестовую распечатку в консоль. Однако изменить значение переменной stop_thread на True и остановить поток я не могу, stop_thread остается False. Как бы я ни игрался с global stop_thread, ничего не меняется. Даже завершение программы по Ctrl-C не прекращает работу потока - продолжается тестовая печать в консоль.
Большая просьба объяснить, что нужно сделать, желательно с примерами.
Спасибо!

Comments

[EugeneVKruglov]

Dr. Bacon, да я уже все испробовал, в т.ч. и объявление stop_thread внутри функции start_thread(). Последний вариант:

def set_globals():
    global stop_thread
    global MyThread
    stop_thread = False

def start_thread():
    print(f'Начало отсчета: {datetime.datetime.utcnow()}')
    print('stop_thread =', stop_thread)
    while not stop_thread:
        print('Работает поток... stop_thread =', stop_thread)
        print(f'Прошло 3 секунды, {datetime.datetime.utcnow()}')
        time.sleep(3)

def main():
    set_globals()
    MyThread = threading.Thread(target = start_thread) 
    MyThread.start()
    # стартуем бота
    bot.polling(non_stop = True)
    
if __name__ == '__main__':
    main()

И все равно поток не останавливается! Можете просто сказать, что я делаю не так?

[EugeneVKruglov]

Dr. Bacon, я не профессиональный программист, а любитель. Профессия моя чрезвычайно далека от IT. На Питоне пробую писать недавно, пока "заходит" с трудом. Лет 10 назад писал на Delphi, получалось.
Да, я в курсе, что локальные и глобальные переменные отличаются областью видимости.
Так тоже пробовал (stop_thread должна меняться в хэндлере, но поток ее не воспринимает, остается False):

@bot.message_handler(content_types = ['text'])
def get_user_text(message):
    if message.text == '/stop_thread':
        if 'stop_thread' in globals():
            stop_thread = True
            print('Получен запрос на остановку потока')
            print('stop_thread =', stop_thread) 
            # в консоли выводится, что значение стало True, но до потока оно почему-то не доходит, 
            # внутри функции start_thread() остается False
#------------
def start_thread():
    print(f'Начало отсчета: {datetime.datetime.utcnow()}')
    print('stop_thread =', stop_thread)
    while not stop_thread:
        print('Работает поток... stop_thread =', stop_thread)
        print(f'Прошло 3 секунды, {datetime.datetime.utcnow()}')
        #bot.send_message(5204768175, f'Прошло 3 секунды, {datetime.datetime.utcnow()}')
        time.sleep(3)
    MyThread.join()

stop_thread = False
MyThread = threading.Thread(target = start_thread) 
MyThread.start()
# стартуем бота
bot.polling(none_stop = True)

Складывается ощущение, что бот работает в своем потоке и не может передать значение переменной потоку, который я создаю. Поэтому и обращаюсь к тем, кто умеет.

[EugeneVKruglov]

Dr. Bacon, только что пример этот увидел. Попробую сейчас

[EugeneVKruglov]

Dr. Bacon, все получилось! Спасибо, дружище. Я действительно не до конца понимал предназначение global. Не злись за тупые вопросы, ведь даже профессионалы когда-то были новичками.