m
про потоки
вернее даже хочется
выделить асинхронную задачу
под эту загрузку
Size: a a a
2020 September 04
M
Кринж
+
m
вернее даже хочется
выделить асинхронную задачу
под эту загрузку
выделить асинхронную задачу
под эту загрузку
у асинкио есть один нюанс
AO
у асинкио есть один нюанс
?
m
чтобы он работал - управление должно регулярно передаваться планировщику в корутинах
m
если в корутине будет вызвана синхронная функция - например работы с файловой системой
m
работа планировщика будет заблокирована
m
class ProcessMessage(Thread):
def __init__(self, name, message):
Thread.__init__(self)
self.name = name
self.message = message
def run(self):
with suppress(Exception):
process_message(self.message)
msg = "%s is running" % self.name
print(msg)AO
есть же асинхронные функции для ФС
m
@bot.message_handler(content_types=['text', 'document', 'audio', 'video', 'voice'])
def create_threads(message):
with suppress(Exception):
name = "Thread #%s" % message.message_id
my_thread = ProcessMessage(name, message)
my_thread.start()НП
У нас в 2024
m
class ProcessMessage(Thread):
def __init__(self, name, message):
Thread.__init__(self)
self.name = name
self.message = message
def run(self):
with suppress(Exception):
process_message(self.message)
msg = "%s is running" % self.name
print(msg)если вкратце - как у меня бот работает
m
объект bot крутит внутри себя поллингом
m
получает апдейты от телеги
и раскидывает эти апдейты по соответствующим декораторам
в одном потоке
и раскидывает эти апдейты по соответствующим декораторам
в одном потоке
m
затем в хендлере создается на каждый апдейт новый поток, в который передается сообщение
m
и дальше уже сообщение в своем потоке обрабатывается, а бот дальше разгребает апдейты
m
ну это на самом деле не очень прям красиво - по хорошему надо пул тредов было бы создать и раскидывать по ним таски, но впадлу
m
это наверное самое близкое что могу подсказать, но вангую что может долго загружаться файл в одном потоке
AO
да, спасибо