Делай все в один :)

Ну а зачем ты стартуешь потоки обработчики?

Хорошоя скорость ?

Ну а зачем ты стартуешь потоки обработчики?

Чтобы не тормозить монитор уведомлений.

Чтобы не тормозить монитор уведомлений.

Какое ещё монитор?

Пришел апдейт Вызвал соответствующий хандлер в потоке

А как можно в бесконечном цикле ждать сообщений от подпроцесса(который тоже работает вечно), и читать данные? Или лучше это сделать через multiprocessing.Process?

Так ты даже не пытался на асинкио писать. Попробуй. Будут вопросы, приходи

Дак где же мне пытаться, если я никак не пойму там что куда и сколько?

Пришел апдейт Вызвал соответствующий хандлер в потоке

В это время получил следующий апдейт и нарушил порядок обработки сообщений. А если упал при обработке - вообще хз что

Дак где же мне пытаться, если я никак не пойму там что куда и сколько?

тогда может не стоит?

так. сейчас объясню как это работает. клиент создает n потоков для общения с серверами. и у него есть поток, которому нужно знать, активно ли соединение с каждым сервером. он эти данные пишет в json. для каждого потока есть булька, которая является статусом активности соединения, она изменяется, если соединение разрывается из-за каких-либо причин. и булька служит параметром для записи. в итоге в json клиент запишет либо [0,1,2] (при бульках true на всех трех серверах) допустим, либо [dead, 1, dead], при false, true, false

В это время получил следующий апдейт и нарушил порядок обработки сообщений. А если упал при обработке - вообще хз что

какой порядок? каждое сообщение самостоятельно

какой порядок? каждое сообщение самостоятельно

От одного человека - нет

От одного человека - нет

контекст разве что сохранять

ну с ВК работать кака-бяка

Maksim если это вакансия - оформи нормально. Если нет - тем более

так. сейчас объясню как это работает. клиент создает n потоков для общения с серверами. и у него есть поток, которому нужно знать, активно ли соединение с каждым сервером. он эти данные пишет в json. для каждого потока есть булька, которая является статусом активности соединения, она изменяется, если соединение разрывается из-за каких-либо причин. и булька служит параметром для записи. в итоге в json клиент запишет либо [0,1,2] (при бульках true на всех трех серверах) допустим, либо [dead, 1, dead], при false, true, false

эта логика работает, но мне похоже где-то удалось налюбиться. в итоге если клиент не цепляется к серверам - то все нормально, в json будет [dead, dead, dead], если запущу на одной из машин - будет [0, dead, dead], но если убить сервер на этой машине принудительно, то сколько не жди, значение не сменится

сокет так просто не убьешь

запросы на коннект он видеть еще будет, а процесса-обработчика как такового уже нет

А он send у тебя вообще делает хоть иногда?

Вообще это корректно так делать?

Как работает у меня код. Идёт requests запрос длительный longpoll. Ждёт ждёт...бац, пришло сообщение. Выдергивпю это сообщение и отдаю его потоку, чтобы он его обрабатывал и потом выслал ответ тому человеку или ещё что то, НО основная программа должна в это время продолжать ждать новые сообщения, т.е создаётся новый longpoll запрос. Представляете, когда борту будут писать через 1 секунду хотябы человек 10, это он пока отошлет ответ первому, сделает запрос, возмет ондующее сообщение и опять уйдёт на обработку. А там ещё 10 напишет и будет вочереди у ВК лежать останется 18 сообщений которые также надо обработать.

Как работает у меня код. Идёт requests запрос длительный longpoll. Ждёт ждёт...бац, пришло сообщение. Выдергивпю это сообщение и отдаю его потоку, чтобы он его обрабатывал и потом выслал ответ тому человеку или ещё что то, НО основная программа должна в это время продолжать ждать новые сообщения, т.е создаётся новый longpoll запрос. Представляете, когда борту будут писать через 1 секунду хотябы человек 10, это он пока отошлет ответ первому, сделает запрос, возмет ондующее сообщение и опять уйдёт на обработку. А там ещё 10 напишет и будет вочереди у ВК лежать останется 18 сообщений которые также надо обработать.

Ну сделай, не знаю ThreadPoolExecutor и очередь

send делает. но я хочу понять, почему settimeout не работает и булька после выхода тайм-аута не false-ится.

Как работает у меня код. Идёт requests запрос длительный longpoll. Ждёт ждёт...бац, пришло сообщение. Выдергивпю это сообщение и отдаю его потоку, чтобы он его обрабатывал и потом выслал ответ тому человеку или ещё что то, НО основная программа должна в это время продолжать ждать новые сообщения, т.е создаётся новый longpoll запрос. Представляете, когда борту будут писать через 1 секунду хотябы человек 10, это он пока отошлет ответ первому, сделает запрос, возмет ондующее сообщение и опять уйдёт на обработку. А там ещё 10 напишет и будет вочереди у ВК лежать останется 18 сообщений которые также надо обработать.

и в чем проблема?

От одного человека - нет

Каждое сообщение - это новое событие и его надо обработать, без рщницы от кого. Это новое уведомление в любом случае.

send делает. но я хочу понять, почему settimeout не работает и булька после выхода тайм-аута не false-ится.

А у тебя точно есть тайм-аут? Я вижу setnonblocking ставишь

Каждое сообщение - это новое событие и его надо обработать, без рщницы от кого. Это новое уведомление в любом случае.

Ну окей

протестил с settimeout, ничего не изменилось, вот именно

и в чем проблема?

То что 1 cpu на vps рублей за 100 в месяц тариф в этих потоках помрет нахрен, в том и проблема?

То что 1 cpu на vps рублей за 100 в месяц тариф в этих потоках помрет нахрен, в том и проблема?

вовсе нет

То что 1 cpu на vps рублей за 100 в месяц тариф в этих потоках помрет нахрен, в том и проблема?

Так огранияь число потоков блин

Не надо запускать 1000000 потоков разом

С твоими знаниями о потоках только за асинкио браться

Так огранияь число потоков блин

Как мне их ограничить?

Не надо запускать 1000000 потоков разом

так они запускаются по мере поступления событий и завершаются по мере быстродействия цпу и интернета

Как мне их ограничить?

https://t.me/ru_python/960324

так они запускаются по мере поступления событий и завершаются по мере быстродействия цпу и интернета

Ну вот не надо так делать

Ну вот не надо так делать

pytelegrambotapi так делает, например

pytelegrambotapi так делает, например

Ещё один повод считать его говном

Ещё один повод считать его говном

Поначалу вроде бы хорошо

Да он говно :)

Вообще хз зачем его берут

Вообще хз зачем его берут

Шо хорошо пахнет то и берут

В частности, документация

В частности, документация

Конечно. Если он не поддерживает все апи телеграма, ему приходится свою доку иметь

Можно попробовать 2 потока. 1 longpoll все время, получил - положил на полку, побежал за следующим. А другой увидел на полке, взял и обработал, следущий с полки взял. Только что бы использовать в качестве полочки бы?

Конечно. Если он не поддерживает все апи телеграма, ему приходится свою доку иметь

Не важно) Главное, что она есть

Можно попробовать 2 потока. 1 longpoll все время, получил - положил на полку, побежал за следующим. А другой увидел на полке, взял и обработал, следущий с полки взял. Только что бы использовать в качестве полочки бы?

Queue

Можно попробовать 2 потока. 1 longpoll все время, получил - положил на полку, побежал за следующим. А другой увидел на полке, взял и обработал, следущий с полки взял. Только что бы использовать в качестве полочки бы?

queuee

Можно попробовать 2 потока. 1 longpoll все время, получил - положил на полку, побежал за следующим. А другой увидел на полке, взял и обработал, следущий с полки взял. Только что бы использовать в качестве полочки бы?

Ты меня вообще не читаешь?

И как это отразиться на работе бота.(((

И как это отразиться на работе бота.(((

С 2 потоками это тоже самое что один

Боже, возьми и проверь

Ты меня вообще не читаешь?

Ты говоришь непонятные мне слова?

Ты говоришь непонятные мне слова?

Так иди блин гуглить

эта логика работает, но мне похоже где-то удалось налюбиться. в итоге если клиент не цепляется к серверам - то все нормально, в json будет [dead, dead, dead], если запущу на одной из машин - будет [0, dead, dead], но если убить сервер на этой машине принудительно, то сколько не жди, значение не сменится

а когда ты убиваешь сервер, чтобы словить такой баг?

а когда ты убиваешь сервер, чтобы словить такой баг?

убиваю, когда соединение уже установлено.

убиваю, когда соединение уже установлено.

А, так понятное дело

в итоге либо connection error, либо timeout error.

Таймаут работает на открытии коннекта (рукопожатии)

А когда ты открыл, конечно ничего не будет. Насколько я знаю, у TCP ping-pong нету, как у тех же вебсокетов, поэтому он и обрубает когда на втором конце молчат

А когда ты открыл, конечно ничего не будет. Насколько я знаю, у TCP ping-pong нету, как у тех же вебсокетов, поэтому он и обрубает когда на втором конце молчат

Ну есть таймауты на чтение/запись

Только надо читать и писать для этого

А когда ты открыл, конечно ничего не будет. Насколько я знаю, у TCP ping-pong нету, как у тех же вебсокетов, поэтому он и обрубает когда на втором конце молчат

Есть

По дефолту начинается часа через 4 что ли

По дефолту начинается часа через 4 что ли

- Видишь суслика? - Нет - И я нет, а он есть

На практике таймаут скорее обрубает

Тишка че мыслей нет на этот счёт?

Я думаю освоить эту профессию

Нет я быстрый просто надо было отлучится

Ты и без него можешь заработать

Как не загляну тут Алиса

Идти в программирование ради денег? Серьезно?)) Любая профессия же должна быть в кайф ну

Идти в программирование ради денег? Серьезно?)) Любая профессия же должна быть в кайф ну

А как же завод?

Идти в программирование ради денег? Серьезно?)) Любая профессия же должна быть в кайф ну

Посадят тебя допиливать код, от которого волосы дыбом становятся, вспомнишь свои слова)