Как поубивать потоки которые я сам же и насоздавал?

Question

[Максим]

Здравствуйте.
Дело такое.
Есть бот для телеграма.

При отправке команды боту, например, /check 192.168.0.1, он создает thread с именем "id отправителя + адрес" (в нашем примере адрес будет 192.168.0.1).
В этом треде бесконечно выполняется цикл, в котором пингуется адрес и результаты отсылаются обратно тому, кто этот thread создал.
Через какое то время, какие то из тредов надо прибить, а какие то оставить.

Соответственно я посылаю команду например /kill 192.168.0.1
и как мне теперь убить thread с именем "id отправителя + адрес"

как получить все активные потоки я понял:

for i in range(threading.active_count()):
               print(threading.enumerate()[i])

а вот что дальше пока не разобрался.

Помогите нубу.

Пример.
рабочий бот по имени TosterQuest_bot
надо сделать pip install pyTelegramBotAPI

import threading, random, time, telebot

bot = telebot.TeleBot('276349923:AAGq2JkAib-OwGo-SrW1lHbh4CTPVFmY0ns')


@bot.message_handler(commands=['cr'])
def handle_text(message):
        param = str(random.randint(1, 1000))
        threadname = str(message.from_user.id) + " " + param
        th = threading.Thread(target=inffync, name=threadname, args=[param])
        th.start()


@bot.message_handler(commands=['list'])
def handle_text(message):
    for i in range(threading.active_count()):
        print(threading.enumerate()[i])


@bot.message_handler(commands=['kill'])
def handle_text(message):
    print("Хочу убивать потоки созданные " + str(message.from_user.id))


def inffync(p):
    while True:
        print(str(random.randint(1, 1000)) + "   " + p)
        time.sleep(5)
bot.polling(none_stop=True, interval=0)

если послать ему команду /cr он создаст тред в котором будет бесконечно выполняться функция которая выводит рандомное число.
если послать /list в консоле появится список запущенных потоков.
вот теперь как оформить убийство одного из них по команде /kill?

Answer 1

[nirvimel]

В цикле проверяется флаг (условие выхода), изначально заданный в False, но сбрасываемый в True обработчиком команды /kill. Удобно использовать dict для соотнесения отдельным потокам флагов выхода.

Comments

[Максим]

Ну это уже делается. Хотелось бы иметь возможность убивать процессы как в диспетчере задач.

[Максим]

видимо не так вас понял.
Ви имели ввиду глобальную переменную завести?

[nirvimel]

Максим: Так процессы убивать легко (зная их pid):

import os
import signal

os.kill(pid, signal.SIGTERM)

А вот треды принудительно убивать нельзя. Кроме того, что это ломает программную логику (захваченные ресурсы не освобождаются), так еще это невозможно технически - стандартные библиотеки не содержат таких средств вообще, а если написать расширение, которое на низком уровне убивает поток ОС, который принадлежит интерпретатору python, то это опрокинет весь интерпретатор, который внутренне не рассчитан на такое.

Answer 2

[Олег Цилюрик]

Соответственно я посылаю команду

По вашей команде (хотя я не понял кому и как вы подаёте команду?) вам нужно выйти из цикла в потоке и выполнить return потоковой функции.

Здесь поищите:
Python - параллелизм
Тонкости использования языка Python: Часть 4. Пара...

Comments

[Максим]

команды отдаются боту при помощи месенджера Telegram.