Threading, как закрыть поток на Python?

Question

[Kisil]

Какими способами можно закрыть поток?
Использую python 3.7 и модуль threading.

Comments

[Leviinson]

Из документации threading:

A thread can be flagged as a “daemon thread”. The significance of this flag is that the entire Python program exits when only daemon threads are left. The initial value is inherited from the creating thread. The flag can be set through the daemon property or the daemon constructor argument.

Note:
Daemon threads are abruptly stopped at shutdown. Their resources (such as open files, database transactions, etc.) may not be released properly. If you want your threads to stop gracefully, make them non-daemonic and use a suitable signalling mechanism such as an Event.

Поэтому точно так-же, как и в скрытом смысле этой цитаты, советую ознакомиться с классом Event.

Answer 1

[Ivan Yakushenko]

Встроенного механизма остановки потока из-вне нет, как вариант можно делать примерно так:

import time
from threading import Thread

stop = False


def some_thread():
    while not stop:
        print(stop)
        time.sleep(0.5)


if __name__ == "__main__":
    some_task = Thread(target=some_thread)
    some_task.start()

    time.sleep(2)
    stop = True
    some_task.join()

Comments

[Kisil]

Не до конца понимаю как это можно сделать в моем случае, мне нужно остановить поток, при этом чтобы dg.py дальше работал, можете помочь?

dg.py

...
from dragonbot import dg 

def start_thread(kit,user_token): 
    global thread

    try:
        t = threading.Thread(target=load_kit, name= 'Поток {}'.format(thread), args=('{}'.format(kit),'{}'.format(user_token)))
        thread = thread + 1
        t.start()

        print(t)
        send_vk("📌Поток удачно запущен",16736)
    except:
        send_vk()

def load_kit(kit,token):
    p = dg(token)

    if kit == 'full':
        asyncio.run(p.full())
    elif kit == 'aver':
        asyncio.run(p.aver())
    elif kit == 'mini':
        asyncio.run(p.mini()) 

if __name__ == '__main__': 
    thread = 0
    start_thread("mini","hdhudgv")

dragonbot.py

class dg(object):
    def __init__(self, token):
        self.vk_session = vk_api.VkApi(token=token)
        self.vk = self.vk_session.get_api()

  #Тут остальные функции

    async def mini(self):
        task_race = asyncio.create_task(self.race(0))
        task_business = asyncio.create_task(self.business(60))
        task_mining = asyncio.create_task(self.mining(180))
        task_job = asyncio.create_task(self.job(360))
        await asyncio.gather(task_race, task_business, task_mining, task_job)

Answer 2

[Сергей Горностаев]

Никаким не надо закрывать. Поток должен сам управлять своим жизненным циклом. Вы можете только отправить ему какой-либо сигнал о необходимости прекратить работу.

Comments

[Kisil]

И как мне это реализовать?

[Сергей Горностаев]

Kisil, использовать глобальную переменную, как советуют в другом ответе, очередь или какой-нибудь из примитивов синхронизации. Выбор наиболее подходящего решения зависит от деталей реализации вашей программы.