Как в Python threading остановить thread корректно?

[Frozone]

Йо, народ! Столкнулся с проблемой при работе с потоками в Python. Я юзаю `threading` модуль, и все работает ок, пока дело не доходит до остановки потока. Вроде все гуглил и даже stackoverflow шерстил, но решения не нашёл. Как вы корректно завершаете execution thread-а? Польщует ли кто-нибудь там `Thread.join()` или как по-умному заглушить бесконечный цикл в потоке? Кидоньте своими best practices и советами!

[admin]

Ждём вас в нашем чате в Телеграмм ==>> @pythoneer_chat

А ТАКЖЕ: Канал о Python, статьи и книги ==>> @pythoneer_ru

[Тропа]

Лучший способ — внедрение флага остановки. Например:

import threading
import time

def worker(stop_flag):
 while not stop_flag.is_set():
  print('Работаем...')
  time.sleep(1)
 print('Поток остановлен!')

stop_flag = threading.Event()
t = threading.Thread(target=worker, args=(stop_flag,))
t.start()

time.sleep(5)
stop_flag.set()
t.join() 

Флагом (`Event`) можно корректно остановить поток. В этом случае не придется экстренно прерывать, да и сам поток завершится корректно.

[Олег Сергеевич]

Лучший способ — внедрение флага остановки. Например:

import threading
import time

def worker(stop_flag):
 while not stop_flag.is_set():
  print('Работаем...')
  time.sleep(1)
 print('Поток остановлен!')

stop_flag = threading.Event()
t = threading.Thread(target=worker, args=(stop_flag,))
t.start()

time.sleep(5)
stop_flag.set()
t.join() 

Флагом (`Event`) можно корректно остановить поток. В этом случае не придется экстренно прерывать, да и сам поток завершится корректно.

Кайф! Реально удобная штука! А что если поток зависнет и не успеет проверить флаг?

[Dzo]

Для корректного завершения потока также можно использовать `daemonic` потоки. Они завершатся автоматически, когда основной поток завершится:

import threading
import time

def worker():
 while True:
  print('Работаем...')
  time.sleep(1)

t = threading.Thread(target=worker)
t.setDaemon(True)
t.start()

time.sleep(3)
print('Основной поток завершился') 

Но со всяким там ресурсом (файлы, сети) придется внимательнее.

[Сергей Александрович]

Для корректного завершения потока также можно использовать `daemonic` потоки. Они завершатся автоматически, когда основной поток завершится:

import threading
import time

def worker():
 while True:
  print('Работаем...')
  time.sleep(1)

t = threading.Thread(target=worker)
t.setDaemon(True)
t.start()

time.sleep(3)
print('Основной поток завершился') 

Но со всяким там ресурсом (файлы, сети) придется внимательнее.

Тру, братан, но `daemon` иногда может подставить. Пусть лучше код сам завершит работу.

[Drakol]

Еще вариант: использовать `Thread.join(timeout)`, но это не всегда выход. Например, если у вас длительные операции внутри потока, возможны кейсы, когда timeout не хватит:

import threading
import time

def worker():
 time.sleep(10)

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

t.join(timeout=5)
if t.is_alive():
 print('Поток еще работает, запускаем экстренное завершение...')
else:
 print('Поток завершился сам') 

[AlexNovikov]

Еще вариант: использовать `Thread.join(timeout)`, но это не всегда выход. Например, если у вас длительные операции внутри потока, возможны кейсы, когда timeout не хватит:

import threading
import time

def worker():
 time.sleep(10)

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

t.join(timeout=5)
if t.is_alive():
 print('Поток еще работает, запускаем экстренное завершение...')
else:
 print('Поток завершился сам') 

Познавательно, но че делать в случае экстренного завершения? Никогда не ясно, когда поток вспотевший будет работать.

[Daredevil]

Если уж совсем emergencyю, то можно использовать `_thread` модуль. Только оч аккуратно!

import _thread
import time

def worker():
 while True:
  print('Работаем...')
  time.sleep(1)

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

time.sleep(3)
_thread.interrupt_main() 

Так делать не рекомендуется, но как наибыстрейший метод сработает.

[Warlock]

Если уж совсем emergencyю, то можно использовать `_thread` модуль. Только оч аккуратно!

import _thread
import time

def worker():
 while True:
  print('Работаем...')
  time.sleep(1)

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

time.sleep(3)
_thread.interrupt_main() 

Так делать не рекомендуется, но как наибыстрейший метод сработает.

Норм, для критических случаев годится! Но юзайте на свой страх и риск))