Как запустить одновременно две бесконечные функции?

Question

[gvnikolaev]

Есть бот на aiogram, он работает на пулинге. Он обрабатывает некоторый инпут с юзера, но есть еще и основная функция, которая играет каждую минуту. Одна из функции не играет вообще, в зависимости от того какую первую вызвал.
Пытался разделить на потоки, 1 раз работают оба элемента, потом выключаются. Это если использовать thread.join(), а если на join() не разделять, то работает только один поток всегда. Подскажите как решить?

for j in range(len(p)):
            print(tagid, ' ' , p[j])
            bot = telebot.TeleBot('токен', threaded=True)
            @bot.message_handler()
            def handle(message):
                if message.text == str(tagid):
                        bot.send_message(message.chat.id, "\n Данные с запроса"+ str(tagid) + "  "+ str(rate1))
                elif message.text != p[j]:
                        bot.send_message(message.chat.id, "\n Такого айди с "+" "+ message.text + "  "+ "нету, попробуйте другой айди")
                 
             
            
                
            #elif message.text != p[j]:
                      #  bot.send_message(message.chat.id, "\n Такого айди с "+" "+ message.text + "  "+ "нету, попробуйте другой айди")
                 
            if __name__ =='__mail__': 
                  
                t = threading.Thread(target=lambda: handle)
                #t2 = threading.Thread(target=lambda: executor.bot.polling())    
                t.start()
                #t2.start()
                bot.polling(non_stop=True)

Answer 1

[Vindicar]

Почему запускаешь bot.polling() в цикле for?

Comments

[gvnikolaev]

А как сделать?

[gvnikolaev]

Кстати сделал так:

def handle(message):
            for j in range(len(p)): 
                print(tagid, ' ' , p[j])
                if  message.text == 'привет':
                    bot.send_message(message.chat.id, "правильно"+ str(tagid))
                else: 
                    bot.send_message(message.chat.id, "напиши привет"+" "+ message.text + "  "+ "нету, попробуйте другой айди")
               
                
            #elif message.text != p[j]:
                      #  bot.send_message(message.chat.id, "\n Такого айди с "+" "+ message.text + "  "+ "нету, попробуйте другой айди")
                 
        #if __name__ =='__main__':   
        t = threading.Thread(target=lambda: handle)
        t2 = threading.Thread(target=lambda: bot.polling())    
        t.start()
                #bot.polling(non_stop=True)
        t2.start()

тода вроде бы как бы работает но выходит такая ошибка и в телеграме очень много приходит сообщений

2022-03-05 08:23:22,306 (__init__.py:690 Thread-916) ERROR - TeleBot: "A request to the Telegram API
was unsuccessful. Error code: 409. Description: Conflict: terminated by other getUpdates request; make sure that only one bot instance is running"

[Vindicar]

gvnikolaev, ты вообще понимаешь что делаешь, или пишешь наугад?
t = threading.Thread(target=lambda: handle)
Этот поток вообще ничего не сделает.
И почему потоки у тебя запускаются внутри handle()?

[gvnikolaev]

Vindicar, первый раз пишу этим кодом брат. поменял снаружи поставил?
t = threading.Thread(target=lambda: handle)
А как сделать подскажи пож-та