V
Это наш. А чем тебе код не угодил?
я могу кинуть тебе версию с моими комментами, но там есть ряд замечаний, начиная от стиля и заканчивая неочевидными решениями. такое впечатление, будто его собирали по кускам из разных источников
Size: a a a
2018 May 29
Z
Это Корбан там кучу функций наплодил, я его сначала пинал за это, но потом забил
Z
я могу кинуть тебе версию с моими комментами, но там есть ряд замечаний, начиная от стиля и заканчивая неочевидными решениями. такое впечатление, будто его собирали по кускам из разных источников
Давай
V
кстати, если у кого-то есть желание запилить свои парсеры протоколов для Отклика (может вы хотите, чтобы в общий релиз вошли какие-то протоколы, для которых мы не написали парсеры) - я думаю, мы можем это устроить. либо сейчас, либо когда мы выкинем код в публичный репозиторий.
Z
Лично мне больше всего стыдно за тот кусок кода, который большие скрины сливал и чистил от мусора. Это ужасно, но лучше не придумал.
Z
кстати, если у кого-то есть желание запилить свои парсеры протоколов для Отклика (может вы хотите, чтобы в общий релиз вошли какие-то протоколы, для которых мы не написали парсеры) - я думаю, мы можем это устроить. либо сейчас, либо когда мы выкинем код в публичный репозиторий.
Могу заняться.
V
Могу заняться.
ок, взял тебя на карандаш))
Z
Лично мне больше всего стыдно за тот кусок кода, который большие скрины сливал и чистил от мусора. Это ужасно, но лучше не придумал.
receive_msg_2 функция
Z
Я, вообще, сейчас переписываю его на Go. Готово процентов 80, но я уперся в проблему с асинхронностью, из-за которой всё зависает. Видимо, я что-то не так делаю.
Z
Могу потом код скинуть, может подскажешь.
V
multiprocessing или threading нельзя использовать просто так, от фонаря. есть два класса задач - I/O-bound и CPU-bound (вообще есть ещё memory-bound и cache-bound, но мы их трогать не будем). multiprocessing используется для CPU-bound задач, когда скорость выполнения задачи ограничивается только мощностью процессора. multiprocessing сильно зависит от железа - ведь у всех разное число ядер, кроме того, multiprocessing сильно грузит проц, т.к. использует все его ресурсы, по сути.
для I/O-bound задач, скорость которых ограничивается скоростью работы подсистем ввода-вывода, используется threading. работа с файлами на диске или почти любая работа с сетью - это I/O-bound задачи.
для I/O-bound задач, скорость которых ограничивается скоростью работы подсистем ввода-вывода, используется threading. работа с файлами на диске или почти любая работа с сетью - это I/O-bound задачи.
V
в Python у потоков есть такая штука, как GIL, которая блокирует выполнение других потоков, пока выполняется один, но как раз для задач с ограничением по скорости I/O это не критично
Z
У меня там от большого количества открытых файлов всё зависало. Приходилось ограничивать.
Z
С камер скриншоты сливаются.
Z
Во много потоков скриншлты делаются и пишутся на диск.
V
ну они пишут скриншоты в файлы. чтобы не висло, нужно использовать пул потоков (либо самодельный, либо multiprocessing.pool.ThreadPool, либо concurrent.futures.ThreadPoolExecutor) с ограничением на максимальное число потоков
Z
Вот так и делал.
Z
Что это за сети?
a
Что это за сети?
DN42 и anonet
Z
В первый раз слышу, если честно.